http://blog.csdn.net/u010054969/article/details/70241478

注意：請確保本地Java環境變量配置成功

1.安裝Zookeeper?
Kafka的運行依賴于Zookeeper，所以在運行Kafka之前我們需要安裝并運行Zookeeper?
1.1 下載安裝文件：?http://mirror.bit.edu.cn/apache/zookeeper/?
1.2 解壓文件（本文解壓到 D:\zookeeper-3.4.8）?
1.3 打開D:\zookeeper-3.4.8\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: D:\zookeeper-3.4.8?
Path: 在現有的值后面添加?;%ZOOKEEPER_HOME%\bin;?
1.7 運行Zookeeper: 打開cmd然后執行zkserver?命令。如果打印以下信息則表示zookeeper已經安裝成功并運行在2181端口。?

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+鼠標右鍵”點擊空白處打開命令提示窗口?
2.7 輸入并執行一下命令以打開kafka:

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

• 1

顯示的信息如下，則表示正常運行?

3.創建topics?
3.1在D:\kafka_2.11-0.10.2.0\bin\windows文件夾中”Shift+鼠標右鍵”點擊空白處打開命令提示窗口

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

• 1

4.打開一個Producer?
4.1在D:\kafka_2.11-0.10.2.0\bin\windows文件夾中”Shift+鼠標右鍵”點擊空白處打開命令提示窗口

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

• 1

5.打開一個Consumer?
5.1在D:\kafka_2.11-0.10.2.0\bin\windows文件夾中”Shift+鼠標右鍵”點擊空白處打開命令提示窗口

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

• 1

注意：以上打開的窗口不要關閉?
然后就可以在Producer控制臺窗口輸入消息了。在消息輸入過后，很快Consumer窗口就會顯示出Producer發送的消息：?

轉載于:https://www.cnblogs.com/davidwang456/articles/8215287.html

總結

以上是生活随笔為你收集整理的Windows平台kafka环境的搭建的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。