基於Kafka的生產者消費者消息處理本地調試

（尊重勞動成果，轉載請註明出處：http://blog.csdn.net/qq_25827845/article/details/68174111冷血之心的博客）

Kafka下載地址：http://download.csdn.net/download/qq_25827845/9798176

安裝解壓就能夠

配置改動zookeeper.properties 與 server.properties改動爲本地路徑，如圖所看到的：

將config文件夾中的zookeeper.properties 與 server.properties複製到bin/windows下。

windows的服務腳本在bin\windows

 

（1）啓動服務:啓動zookeeper:  

  zookeeper-server-start.bat zookeeper.properties      

cd到bin\windows文件夾, 並把zookeeper.properties  複製到這裏或者在命令中帶上絕對路徑

 

（2）啓動kafka:  

kafka-server-start.bat server.properties

 

（3）關閉服務:在啓動服務的cmd窗體, 按ctrl+c另開窗體, 

運行腳本kafka-server-stop.bat zookeeper-server-stop.bat

 

（4）消費測試:創建topic:  

kafka-topics.bat --create --zookeeper localhost:2181--replication-factor 1 --partitions 1 --topic test_ywq

 

（5）創建一個Producer, 打開一個cmd窗體,運行: 

kafka-console-producer.bat --broker-list localhost:9092 --topic test_ywq

 

（6）創建一個Consumer, 打開一個cmd窗體,運行:

kafka-console-consumer.bat --zookeeper localhost:2181 --topic test_ywq

 

（7）生產和消費測試：

當在生產者的消息爲hello？時。可以看到。在消費者裏邊可以消費到hello？

心得總結：
1. produce啓動的時候參數使用的是kafka的port

consumer啓動的時候使用的是zookeeper的port；
2.必須先建立topic才幹使用。
3.topic本質是以文件的形式儲存在zookeeper上的。

 

假設對你有幫助。記得點贊哦~歡迎你們關注個人博客，可以進羣366533258一塊兒交流學習哦~