备注:基于kafka_2.12-2.5.0版本:(已经验证通过)
查看kafka的安装目录
find / -name kafka* -type d
查询所有topic信息:
./bin/kafka-topics.sh --list --zookeeper localhost:2181
查询指定topic的详细信息:
./bin/kafka-topics.sh —describe —zookeeper localhost:2181 —topic event_topic
示例结果:
查询匹配指定内容的消息内容:
./bin/kafka-console-consumer.sh --bootstrap-server 10.1.77.129:9092 --topic event_topic --from-beginning | grep "0356000003637589783349260"
查看所有消费者group信息:
./bin/kafka-consumer-groups.sh --command-config config/consumer.properties --bootstrap-server 10.1.77.95:9092 --list
示例结果:
完整文档链接:https://blog.csdn.net/u012483153/article/details/107839950