怎么查看Kafka的Topic消费情况

这篇文章主要介绍了怎么查看Kafka的Topic消费情况，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。

成都创新互联长期为数千家客户提供的网站建设服务，团队从业经验10年，关注不同地域、不同群体，并针对不同对象提供差异化的产品和服务；打造开放共赢平台，与合作伙伴共同营造健康的互联网生态环境。为华亭企业提供专业的成都网站制作、网站建设，华亭网站改版等技术服务。拥有10余年丰富建站经验和众多成功案例,为您定制开发。

1.文档编写目的

在我们的应用程序消费Kafka的Topic消息时，我们会关注Topic中消息总量以及消费情况，那接下来Fayson就主要介绍下如何在CDH集群中使用命令行的方式查看Topic的消费情况。

• 本次Fayson的测试环境为

1.CM和CDH版本为5.15

2.Redhat7.4

3.Kafka 0.10.2+kafka2.2.0

2.命令行查看

在Kafka的脚本里提供了kafka-run-class.sh的脚本，使用该脚本查看Consumer组内消费Topic的Offset情况。

1.在命令行执行如下命令查看指定Topic及ConsumerGroup的消费情况

[root@cdh01 bin]# kafka-run-class kafka.tools.ConsumerOffsetChecker --zookeeper cdh01.fayson.com:2181 --group test --topic kafka_kudu_topic_offset_3

第一次执行查看到kafka_kudu_topic_offset_3的testgroup组各个Partition的Offset消费情况以及每个Partition的总消息量。

2.kafka_kudu_topic_offset_3的Topic发送600条消息，再次执行命令查看消费情况

此时没有消费的应用运行，可以看到Offset的数据未发生变化，而logSize的数据量有增加，每个partition的数量增加200条，刚好为我发送的消息数量。

3.启动消费程序消费Topic的消息，再次执行命令查看消费情况

在消费应用运行时，每个Partition的Offset数据发生变化，此时的Offset的数据与logSize的数据一致，在应用日志中也无新的消息接收，说明Topic的消息已被testgroup组消费完。

感谢你能够认真阅读完这篇文章，希望小编分享的“怎么查看Kafka的Topic消费情况”这篇文章对大家有帮助，同时也希望大家多多支持创新互联，关注创新互联行业资讯频道，更多相关知识等着你来学习!