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的埠

consumer啟動的時候使用的是zookeeper的埠；
2.必須先建立topic才能使用；
3.topic本質是以檔案的形式儲存在zookeeper上的。

如果對你有幫助，記得點贊哦~歡迎大家關注我的部落格，可以進群366533258一起交流學習哦~