Kafka - 基于非 ZooKeeper 的消费者与基于 ZooKeeper 的消费者

Question

当我浏览文档时，我遇到了以下短语 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语言有关吗（似乎在cmets中提到了java）。

• 是否与 Zookeeper 消费者连接 zk 而非 zk 连接代理之类的事情有关？

PS : 2.5 文档中似乎没有此内容

Answer 1

在 Kafka 0.9 之前，消费者使用 Zookeeper 进行协调。从那时起，消费者现在只连接到 Kafka。

因此，kafka-consumer-groups.sh 支持显示“基于动物园管理员”（即旧消费者）的组详细信息。

“老消费者”在 Kafka 0.11 中被弃用，最终在 2.1.0 中被移除。 kafka-consumer-groups.sh 也已更新以删除任何提及它的内容。

所以基本上，忽略它，它是一个不再存在的遗留客户端。