1 查询kafka位置
find / -name kafka
find / -name kafka-consumer-groups.sh
在目录下,执行下面的脚本,查询kafka积压消息
2 查询消费者组
./kafka-consumer-groups.sh --bootstrap-server 192.168.xx.xx:9097 --list
3 查询消费者组详情
./kafka-consumer-groups.sh --bootstrap-server 192.168.xx.xx:9097 --describe --group groupname
文章来源:https://www.toymoban.com/news/detail-700222.html
4 查询topic当前消费偏移值
./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 192.168.xx.xx:9097 --topic topicname --partitions 0
5 通过Offset Explore工具查询当前offset值
文章来源地址https://www.toymoban.com/news/detail-700222.html
到了这里,关于kafka 积压消息查询的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!