when i use kafka0.8.x,i can get all group list with zookeeper by path /consumers/group_id
, because offsets will commit to zookeeper in 0.8.x.
But in version of 0.10.x, offsets commited to kafka broker like a path /brokers/topics/__consumer_offsets
and path /consumers
in zookeeper has nothing. so I can not get consumer group list by zookeeper.
To list all consumer groups across all topics:
bin/kafka-consumer-groups.sh --bootstrap-server broker1:9092 --list
To view offsets for the consumer group:
bin/kafka-consumer-groups.sh --bootstrap-server broker1:9092 --describe --group test-consumer-group
See Managing Consumer Groups for detailed information.
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With