Я использую кластер Kafka с некоторыми производителями и потребителями.
Когда я использовал Kafka версии 0.8, у потребителя было свойство 'retries', в котором указано максимальное количество попыток получения сообщений.Несмотря на то, что Kafka обновлен до версии 1.0, свойство «повторные попытки» отсутствует, но остаетсяconnect.backoff.ms и reconnect.backoff.max.ms.
Поэтому у меня есть вопрос.Если бы существовала тема А, и у одного из брокеров был отказ, который был лидером некоторых разделов темы А. KafkaConsumer, который потребляет этот раздел, будет пытаться повторно соединиться, пока новый лидер не будет избран с бесконечным откатом?