监控Kafka集群消费组信息

查询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
©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容