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

注意：請確保本地Java環(huán)境變量配置成功

1.安裝Zookeeper?
Kafka的運(yùn)行依賴于Zookeeper，所以在運(yùn)行Kafka之前我們需要安裝并運(yùn)行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 添加如下系統(tǒng)變量：ZOOKEEPER_HOME: D:\zookeeper-3.4.8?
Path: 在現(xiàn)有的值后面添加?;%ZOOKEEPER_HOME%\bin;?
1.7 運(yùn)行Zookeeper: 打開cmd然后執(zhí)行zkserver?命令。如果打印以下信息則表示zookeeper已經(jīng)安裝成功并運(yùn)行在2181端口。?

2.安裝并運(yùn)行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下運(yùn)行的，此文件夾下還有個 windows文件夾，里面是windows下運(yùn)行的.bat命令腳本?
2.6 在D:\kafka_2.11-0.10.2.0文件夾中”Shift+鼠標(biāo)右鍵”點(diǎn)擊空白處打開命令提示窗口?
2.7 輸入并執(zhí)行一下命令以打開kafka:

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

• 1

顯示的信息如下，則表示正常運(yùn)行?

3.創(chuàng)建topics?
3.1在D:\kafka_2.11-0.10.2.0\bin\windows文件夾中”Shift+鼠標(biāo)右鍵”點(diǎn)擊空白處打開命令提示窗口

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+鼠標(biāo)右鍵”點(diǎn)擊空白處打開命令提示窗口

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+鼠標(biāo)右鍵”點(diǎn)擊空白處打開命令提示窗口

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

• 1

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

轉(zhuǎn)載于:https://www.cnblogs.com/davidwang456/articles/8215287.html

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。