在安裝zookeeper前，請確認java環境已經正確安裝和配置JAVA_HOME環境變數。否則無法啟動zookeeper和kafka的。

1.安裝Zookeeper 
Kafka的執行依賴於Zookeeper，所以在執行Kafka之前我們需要安裝並執行Zookeeper 3.4.13
1.1 下載安裝檔案： http://mirror.bit.edu.cn/apache/zookeeper/ 
1.2 解壓檔案（本文解壓到 D:\soft\bigdata\zookeeper-3.4.13） 
1.3 開啟D:\soft\bigdata\zookeeper-3.4.13\conf，把zoo_sample.cfg重新命名成zoo.cfg 
1.4 從文字編輯器裡開啟zoo.cfg 
1.5 修改dataDir和dataLogDir儲存路徑 
dataDir=D:\data\logs\zookeeper 
dataLogDir=D:\data\logs\zookeeper 
1.6 新增如下系統變數：ZOOKEEPER_HOME:

2.安裝並執行Kafka 
2.1 下載安裝檔案： http://kafka.apache.org/downloads.html 
2.2 解壓檔案（本文解壓到 D:\kafka_2.11-0.10.2.0） 
2.3 開啟D:\kafka_2.11-0.10.2.0\config\ server.properties 
2.4 把 log.dirs的值改成 log.dirs=D:\data\logs\kafka 
2.5 D:\kafka_2.11-0.10.2.0\bin資料夾下的.sh命令指令碼是在shell下執行的，此資料夾下還有個 windows資料夾，裡面是windows下執行的.bat命令指令碼 
2.6 在D:\kafka_2.11-0.10.2.0資料夾中”Shift+滑鼠右鍵”點選空白處開啟命令提示視窗 （本文用的shi
是powershell， 輸入並執行一下命令以開啟kafka:

.\bin\windows\kafka-server-start.bat .\config\server.properties

顯示的資訊如下，則表示正常執行

提示：把這個命令及引數放到一個bat檔案中，儲存到D:\kafka_2.11-0.10.2.0資料夾中，雙擊執行也是可用的。下面的命令也是如此。

3.建立topics 
3.1在D:\kafka_2.11-0.10.2.0\bin\windows資料夾中”Shift+滑鼠右鍵”點選空白處開啟powershell命令提示視窗

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

powershell中，執行命令不成功時，如果有如下提示，請在命令名稱前加：“.\”

4.開啟一個Producer 
4.1在D:\kafka_2.11-0.10.2.0\bin\windows資料夾中”Shift+滑鼠右鍵”點選空白處開啟命令提示視窗

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

建立好下面的消費者後，就可用在上面這個生產者視窗輸入資訊了。

5.開啟一個Consumer 
5.1在D:\kafka_2.11-0.10.2.0\bin\windows資料夾中”Shift+滑鼠右鍵”點選空白處開啟命令提示視窗，執行命令：

.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --from-beginning --topic monitorupload

網上一些例子用下面的命令建立消費者：

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

但在我這個環境下執行這個命令，會提示zookeeper是一個不可識別的選項的錯誤：

以上開啟的視窗不要關閉 

然後就可以在Producer控制檯視窗輸入訊息了。在訊息輸入過後，很快Consumer視窗就會顯示出Producer傳送的訊息

呃，，，，在生產者視窗輸入中文，消費者視窗輸出亂碼。。。。開發時要注意啦