kafka查看消费组消费详情

kafka 在 0.9 版本之后,kafka的消费者组和offset信息就不存zookeeper了。

0.9 之前版本查看所有消费组:

1
2
3
4
5
6
7
8
./kafka-consumer-groups.sh --zookeeper 127.0.0.1:2181 --list

erro-info-group
console-consumer-64036
console-consumer-98298
logstash-new
console-consumer-89310
console-consumer-48800

新版本 0.9 版本之后查看所有消费组

1
2
3
4
kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list 

test-info
nginxlog

显示某个消费组的消费详情(仅支持offset存储在zookeeper上的)

1
bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper localhost:2181 --group logstash-new

显示某个消费组的消费详情(支持0.9版本+)

1
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --describe --group nginxlog
感谢您的支持!