大家好,我是好学的小师弟,kafka-tool出问题的情况下,可以用命令行来查看kafka信息
1.找到kafka所在的安装目录
find / -name kafka
2.列出有哪些用户组来消费:
./kafka-consumer-groups.sh --bootstrap-server 192.168.100.77:9092 --list
#bootstrap-server 安装kafka的服务器地址
3.查看某个用户组的kafka消息消费情况,有没有数据积压
./kafka-consumer-groups.sh --bootstrap-server 192.168.100.77:9092 --describe --group 用户组名字
#可用第二条命令查询用户组的ID
#执行后的效果
TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID
这是你的topic消息队列id 0 138 189 51 - - -
# CURRENT-OFFSET 这是当前已经消费了的偏移量
# LAG 这是消息积压数量
4.查看topic某分区数据偏移量(offset)最大值,就是看目前Kafka里有多少条消息
./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 192.168.100.77:9092 --topic topic队列名字 --partitions 0
新人创作不易,觉得不错的看官,点个赞吧,么么哒!!!
转载注明出处!文章来源:https://www.toymoban.com/news/detail-505269.html
文章来源地址https://www.toymoban.com/news/detail-505269.html
到了这里,关于【kafka】服务器命令行查询kafka信息消费情况的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!