Kafka消息消费问题排查涉及到的命令

1. 查看Kafka所有group

bin/kafka-consumer-groups.sh --bootstrap-server Kafka的IP地址:9092 --list

2. 查看Kafka指定topic的消费情况(指定group为pay)

bin/kafka-consumer-groups.sh --describe --bootstrap-server Kafka的IP地址:9092 --group pay

3. 查询Kafka下的所有topic

kafka-topics.sh --zookeeper zookeeper的IP地址:2181 --list

4. 手动消费消息

bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic ccb_zr_pay_result_notify_for_quick_consultation_by_url --from-beginning
原文地址:https://www.cnblogs.com/miaoying/p/15425621.html