【kafka】服务器命令行查询kafka信息消费情况

举报
钧瑜 发表于 2023/10/29 01:16:15 2023/10/29
【摘要】 【kafka】服务器命令行查询kafka信息消费情况

大家好,我是hw_cloud 钧瑜,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

2个博客id : 钧瑜 /好学的小师弟

【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息, 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。