30 March 2017

只查看所有Topic:

./kafka-topics.sh –list –zookeeper solr2:2181 删除主题:

./kafka-topics.sh –zookeeper solr2:2181 –delete –topic 0085000

  • 打开消费端控制台 ./kafka-console-consumer.sh -zookeeper solr2:2181 –from-beginning –topic test

  • 打开生产者控制台 ./kafka-console-producer.sh –broker-list localhost:9092 –topic test

然后输入消息,即可在消费端接收到消息

参考网址: http://jiangxiaoqiang.com/2016/10/29/kafka-delete-topic/

http://blog.csdn.net/itleochen/article/details/18407063





Fork me on GitHub