未从zookeeper发现活动使用者

Question

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

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

null

• 在kafka偏移量监视工具中列出活动使用者

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

zookeeper和kafka broker之间的整合似乎起到了作用，自从我尝试：

[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]来启用它。