kafka 在 0.9 版本之后,kafka的消费者组和offset信息就不存zookeeper了。
0.9 之前版本查看所有消费组:
1 | ./kafka-consumer-groups.sh --zookeeper 127.0.0.1:2181 --list |
新版本 0.9 版本之后查看所有消费组
1 | kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list |
显示某个消费组的消费详情(仅支持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 |