kafka消息堆积查询
执行命令需要在kafka的bin目录下执行，或使用绝对路径运行。列出正在进行消费的group ID（ip:port为kafka的ip 端口，可能需要修改） ：./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092--list --new-consumer查询指定group Id的topic消费情况(groupID填写上边命令查询到的
·
执行命令需要在kafka的bin目录下执行，或使用绝对路径运行。
- 列出正在进行消费的group ID（ip:port为kafka的ip 端口，可能需要修改） ：
./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --list --new-consumer
- 查询指定group Id的topic消费情况(groupID填写上边命令查询到的group即可)
kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --describe --new-consumer --group groupId
LAG为堆积未处理的消息，LOG-END-OFFSET为消息总偏移量，CURRENT-OFFSET 当前偏移量
华为开发者空间，是为全球开发者打造的专属开发空间，汇聚了华为优质开发资源及工具，致力于让每一位开发者拥有一台云主机，基于华为根生态开发、创新。
更多推荐
2
0- 0
已为社区贡献2条内容
所有评论(0)