查询topic列表:
/kafka/bin/kafka-topics.sh --bootstrap-server master:9092 --list
获取消费组消息:
/kafka/bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper master:2181 --group mytest_01
或
/kafka/bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --bootstrap-server master:9092 --group mytest_01
若显示 kafka.tools.ConsumerOffsetChecker 不存在,则当前版本kafka.tools.ConsumerOffsetChecker不可用,更换 kafka-consumer-groups.sh 获取:
/kafka/bin/kafka-consumer-groups.sh --bootstrap-server master:9092 --describe --group mytest_01
结果示例:CURRENT-OFFSET -> 已消费条数; LOG-END-OFFSET -> 总条数; LAG -> 未消费条数;
TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID
mytest 0 97071 97076 5 consumer-1-24b5df0b-6afd-4d0e-a385-c836703ffcd5 /192.168.109.121 consumer-3