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

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

但是在0.10.x的版本中,offset提交给kafka代理,就像一个路径/brokers/topics/__consumer_offsets和/consumerszookeeper中的路径一样.所以我无法通过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

有关详细信息,请参阅管理使用者组