（尊重勞動成果，轉載請註明出處：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一起交流學習哦~

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