我如何使用kafka0获取所有组列表。10.x

How can i get all group list with kafka0.10.x

当我使用kafka0.8.x时,我可以通过路径/consumers/group_id获取zookeeper的所有组列表,因为偏移量将在0.8.x.[=14中提交给zookeeper =]

但在 0.10.x 版本中,像路径 /brokers/topics/__consumer_offsets 和 zookeeper 中的路径 /consumers 一样提交给 kafka broker 的偏移量没有任何内容。所以我无法通过zookeeper获取消费者组列表。

列出所有主题的所有消费者组:

 bin/kafka-consumer-groups.sh --bootstrap-server broker1:9092 --list

查看消费者组的偏移量:

 bin/kafka-consumer-groups.sh --bootstrap-server broker1:9092 --describe --group test-consumer-group

有关详细信息,请参阅 Managing Consumer Groups