У меня следующий сценарий, и я хотел бы понять ожидаемое поведение.
- Создано Kafka Consumer
- Kafka Consumer подписывается на некоторые темы
- Сообщения используются, и затем потребитель kafka простаивает в течение некоторого времени, намного превышающего
max.poll.interval.ms конфигурацию - Согласно документации kafka, связанной ниже, kafka перебалансирует раздел с другим активным потребителем kafka, так как
KafkaConsumer::poll не вызывался в течение длительного времени.
Теперь, через некоторое времяX секунд (больше, чем max.poll.interval.ms конфигурация) мы начинаем повторно использовать того же потребителя kafka
- Будет ли Kafka переназначать раздел, когда это произойдет, и существующий потребитель kafka начнет получать сообщения длятемы с подпиской?
ИЛИ
- Нужно ли изящно закрывать потребителя кафки и создавать нового потребителя кафки, чтобы снова начать потреблять?
Справка: https://kafka.apache.org/10/javadoc/?org/apache/kafka/clients/consumer/KafkaConsumer.html