4

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

但是在 0.10.x 版本中,提交给 kafka 代理的偏移量就像路径一样/brokers/topics/__consumer_offsets,而 zookeeper 中的路径/consumers什么都没有。所以我无法通过zookeeper获取消费者组列表。

4

1 回答 1

13

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

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

查看消费者组的偏移量:

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

有关详细信息,请参阅管理消费者组

于 2017-01-16T09:27:52.587 回答