Kafka - 非基于 ZooKeeper 的消费者与基于 ZooKeeper 的消费者
Kafka - non-ZooKeeper-based consumers Vs ZooKeeper based consumers
在浏览文档时,我遇到了以下短语
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 consumer connect 与 zk 而 non zk connect 与 broker 之类的东西有关?
PS : 这似乎不存在于 2.5 文档中
在Kafka 0.9之前,Consumers使用Zookeeper进行协调。从那时起,消费者现在只连接到 Kafka。
因此,kafka-consumer-groups.sh
支持显示 "zookeeper-based"(即旧消费者)组详细信息。
"old consumer" 在 Kafka 0.11 中被弃用,最终在 2.1.0 中被删除。 kafka-consumer-groups.sh
也已更新,删除了对它的任何提及。
所以基本上,忽略它,它是一个不再存在的遗留客户端。
在浏览文档时,我遇到了以下短语 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 consumer connect 与 zk 而 non zk connect 与 broker 之类的东西有关?
PS : 这似乎不存在于 2.5 文档中
在Kafka 0.9之前,Consumers使用Zookeeper进行协调。从那时起,消费者现在只连接到 Kafka。
因此,kafka-consumer-groups.sh
支持显示 "zookeeper-based"(即旧消费者)组详细信息。
"old consumer" 在 Kafka 0.11 中被弃用,最终在 2.1.0 中被删除。 kafka-consumer-groups.sh
也已更新,删除了对它的任何提及。
所以基本上,忽略它,它是一个不再存在的遗留客户端。