1:查询消费数据,必须要指定组。查看kafka组使用以下命令

[root@hadoop01 kafka_2.11-2.1.0]#  bin/kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --list


2:查看消费情况

[root@hadoop01 kafka_2.11-2.1.0]#  bin/kafka-consumer-groups.sh --describe --bootstrap-server 127.0.0.1:9092 --group invoiceUpload

TOPIC
PARTITION
CURRENT-OFFSET
LOG-END-OFFSET
LAG
CONSUMER-ID
HOST
CLIENT-ID
topic名字分区id当前已消费的条数总条数未消费的条数消费id主机ip客户端id


 
————————————————
版权声明:本文为CSDN博主「大金粒」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。
原文链接:https://blog.csdn.net/lucklilili/article/details/107553499

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐