zookeeper 中的 Kafka 消费者路径为空?
Kafka consumers path in zookeeper is empty?
我使用 zkCli.sh
列出 zookeeper
中的 kafka
路径。
通过Kafka+data+structures+in+Zookeeper文档,我发现文档中的所有路径都可以匹配文档,除了consumers
路径。
命令ls /consumers
,响应[]
,但kafka manager of yahoo可以获取消费者信息,如LogSize
,Consumer Offset
等
这就是不再依赖 Zookeeper 的新消费者。 Zk 节点 '/consumers' 仅供老消费者使用。之所以能在 KafkaManager 中找到消费者信息,可能是因为它已经支持新的消费者了。
Kafka 附带一个命令 kafka-consumer-groups.sh,可用于检查旧消费者和新消费者的状态。
我使用 zkCli.sh
列出 zookeeper
中的 kafka
路径。
通过Kafka+data+structures+in+Zookeeper文档,我发现文档中的所有路径都可以匹配文档,除了consumers
路径。
命令ls /consumers
,响应[]
,但kafka manager of yahoo可以获取消费者信息,如LogSize
,Consumer Offset
等
这就是不再依赖 Zookeeper 的新消费者。 Zk 节点 '/consumers' 仅供老消费者使用。之所以能在 KafkaManager 中找到消费者信息,可能是因为它已经支持新的消费者了。
Kafka 附带一个命令 kafka-consumer-groups.sh,可用于检查旧消费者和新消费者的状态。