053 kafka自帶的生產者與消費者測試


1.命令

  

 

2.啟動生產者

  bin/kafka-console-producer.sh --topic beifeng --broker-list linux-hadoop01.ibeifeng.com:9092,linux-hadoop01.ibeifeng.com:9093,linux-hadoop01.ibeifeng.com:9094.linux-hadoop01.ibeifeng.com:9095

 

3.啟動消費者

  bin/kafka-console-consumer.sh --topic beifeng --zookeeper linux-hadoop01.ibeifeng.com:2181/kafka

 

4.在生成者的控制台上添加數據

  

 

5.消費者接收到的數據

  

 


免責聲明!

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



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