我如何使用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。
当我使用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。