zookeeper.session.timeout.ms относится к потребителю или брокеру?

Question

zookeeper.session.timeout.ms: время ожидания сеанса ZooKeeper.Если потребитель не сможет отправить ZooKeeper сообщение в течение этого периода времени, он считается мертвым и произойдет перебалансировка.

Насколько я понимаю, эта конфигурация является настройкой брокера.Из команды netstat также видно, что к zookeeper подключается только kafka.Потребитель кафки вообще не подключается к зоопарку.Кто-нибудь может объяснить, что означает потребитель в этой настройке?

Answer 1

В старых версиях Kafka (до 0.8, позже это было необязательно), потребитель использовал ZooKeeper для хранения смещений.Теперь для этого используется внутренняя тема Kafka, и потребитель больше не общается с ZooKeeper.

См. Также: https://www.confluent.io/blog/tutorial-getting-started-with-the-new-apache-kafka-0-9-consumer-client/