kafka命令行腳本使用


zookeeper集群部署:http://www.cnblogs.com/ding2016/p/8280696.html

kafka集群部署:http://www.cnblogs.com/ding2016/p/8282907.html

 

測試環境

      

 

測試流程:①主線:創建topoic,生產消息,消費消息;

      ②流程命令會連接不同的節點,可以順帶檢測集群消息同步情況;

      

測試步驟

1. 先創建一個Topic

   [root@server-1 bin]# ./kafka-topics.sh --create --zookeeper 192.168.1.21:2181 --replication-factor 3 --partitions 2 --topic google 

  

 

2. 查看一下建好的Topic

   [root@server-1 bin]# ./kafka-topics.sh --list --zookeeper 192.168.1.23:2181 

  

 

3. 在建好的Topic下生產消息

   [root@server-1 bin]# ./kafka-console-producer.sh --broker-list 192.168.1.21:9092 --topic google 

  

 

4. 消費指定Topic下的消息

   [root@server-1 bin]# ./kafka-console-consumer.sh --zookeeper 192.168.1.22:2181 --topic google --from-beginning 

  

 

5. 刪除指定Topic

  先list一下,然后刪除:

   [root@server-1 bin]# ./kafka-topics.sh --delete --zookeeper 192.168.1.23:2181 --topic google 

  

 

結束.


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM