Kafka - потребители, не использующие ZooKeeper, против потребителей, использующих ZooKeeper - PullRequest
Новая
       13

Kafka - потребители, не использующие ZooKeeper, против потребителей, использующих ZooKeeper

0 голосов
/ 18 июня 2020

Просматривая документацию, я наткнулся на следующую фразу: https://kafka.apache.org/20/documentation.html#basic_ops_consumer_lag

bin / kafka-consumer-groups. sh - - bootstrap -server localhost: 9092 --describe --group my-group

Примечание. Будет показана информация только о потребителях, которые используют Java API-интерфейс потребителя (не на основе ZooKeeper потребители).

Этот инструмент также работает с потребителями на основе ZooKeeper:

bin / kafka-consumer-groups. sh --zookeeper localhost: 2181 --describe --group my- group

Примечание. При этом будет отображаться информация только о потребителях, использующих ZooKeeper (а не о тех, кто использует Java потребительский API).

В чем разница между не-ZooKeeper потребители против потребителей на базе ZooKeeper - это связано с языком java (кажется, java упоминается в комментариях).

  • Это связано с чем-то вроде соединения потребителя zookeeper с zk, а не zk подключиться к брокерам?

PS: Похоже, этого нет в документации 2.5

1 Ответ

1 голос
/ 18 июня 2020

До Kafka 0.9 Потребители использовали Zookeeper для координации. С тех пор потребители теперь подключаются только к Kafka.

По этой причине kafka-consumer-groups.sh поддерживает отображение сведений о группе «на основе zookeeper» (ie старый потребитель).

«Старый потребитель» устарел в Kafka 0.11 и окончательно удален в 2.1.0. kafka-consumer-groups.sh также был обновлен, чтобы удалить все упоминания о нем.

Так что просто игнорируйте его, это устаревший клиент, которого больше не существует.

...