Zookeeper中的Kafka消费者路径是空的?

Bab*_*hou 2 apache-kafka apache-zookeeper

我使用zkCli.sh列出kafka的路径zookeeper

通过Kafka+data+structures+in+Zookeeper文档,我发现文档中的所有路径都可以匹配文档,consumers路径除外。

命令ls /consumers,响应[],但是yahoo 的 kafka manager可以获取消费者信息,例如LogSizeConsumer Offset等等。

ame*_*tic 5

那是不再依赖 Zookeeper 的新消费者。Zk 节点 '/consumers' 仅适用于老消费者。您可以在 KafkaManager 中找到消费者信息的原因可能是因为它已经支持新的消费者。

Kafka 附带了一个命令 kafka-consumer-groups.sh,可用于检查旧消费者和新消费者的状态。