1、查询topic,进入kafka目录:
bin/kafka-topics.sh –list –zookeeper localhost:2181
 
2、查询topic内容:
bin/kafka-console-consumer.sh –bootstrap-server localhost:9092 –topic topicName –from-beginning

版权声明:本文为jylsgup原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://www.cnblogs.com/jylsgup/p/10247685.html