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