В старых пользовательских конфигах есть параметр:
rebalance.max.retries:
Когда новый потребитель присоединяется к группе потребителей, наборпотребители пытаются «перебалансировать» нагрузку, чтобы назначить разделы каждому потребителю.Если набор потребителей изменится во время выполнения этого назначения, перебалансировка не удастся и повторите попытку.Этот параметр контролирует максимальное количество попыток, прежде чем отказаться.
Этот параметр кажется мне очень полезным, и я хотел изменить его на большее число.Потому что мои потребители перестают пытаться присоединиться к группе через некоторое время.Так что, если я скажу, что мои потребители повторяют гораздо больше времени, я думаю, это могло бы решить мою проблему.Но я использую нового потребителя Kafka (kafka-clients - 1.1.0), и такого параметра нет.
Существует ли какой-либо параметр, эквивалентный этому параметру?Как я могу заставить своих потребителей повторять гораздо больше времени, чтобы вызвать изменение баланса с помощью запроса joinGroup?