Zookeeper 未发现活跃消费者

Question

我是 apache kafka 的新手，我已经在我自己部署的 kubernetes 集群上建立了一个带有 zookeeper 的 kafka-broker。 （2个单独的豆荚）

没有明显的错误日志，一切正常，包括：

• 创建主题
• 通过 bin/kafka-console-producer.sh 生成消息
• 通过 bin/kafka-console-consumer.sh 订阅（消费）消息
• 在 zookeeper CLI (ls /brokers/ids) 中列出主题

除了：

• 在kafka offset monitoring tool 中列出活跃的消费者

当我尝试在 zookeeper CLI 中列出活动消费者或在监控工具中查看活动消费者时，我也会得到空结果。（虽然我有一个消费者会话正在运行，但如上所述）

从我尝试开始，zookeeper 和 kafka 代理之间的集成似乎可以正常工作：

[zk: localhost:2181(CONNECTED) 1] ls /brokers/topics
[topic1, topic2] 
[zk: localhost:2181(CONNECTED) 2] ls /consumers
[] 

我错过了什么吗？？

Answer 1

消费者数据不再存储在 Zookeeper 中（从 0.9 开始）。消费者组数据现在直接存储在 Kafka 中。

要检查消费者组的状态，您应该使用kafka-consumer-groups.sh 工具。例如：

./bin/kafka-consumer-groups.sh --bootstrap-server [HOST:PORT] --group [GROUP]

请注意，只有属于提交偏移量的组的消费者是可见的。默认情况下，kafka-console-consumer.sh 没有。您需要指定--group [GROUP] 才能启用它。