kafka消息阻塞排查

2023-04-23  本文已影响0人  催化剂

kafka大讲座:https://www.cnblogs.com/zackstang/category/1520711.html

1、#找到kafka目录,并进入

find / -name kafka-consumer-groups.sh

cd /opt/kafka_2.12-1.0.0/bin

2、# 查看iot的消费组

./kafka-consumer-groups.sh --bootstrap-server kafka-server:9092 --list --new-consumer | grep iot

./kafka-consumer-groups.sh --bootstrap-server kafka-server:9092 --describe --new-consumer --group ${topic} 

内容是上面查询的结果 例如 iot-mongo-sink-server-group_iot-monitor-sink-data

完整命令举例:./kafka-consumer-groups.sh --bootstrap-server kafka-server:9092 --describe --new-consumer --group iot-mongo-sink-server-group_iot-monitor-sink-data

上一篇 下一篇

猜你喜欢

热点阅读