Windows單機配置Kafka環境

首先確保機器已經安裝好Zookeeper，Zookeeper安裝參考 Windows單機配置Zookeeper環境

然后確保Zookeeper是正常啟動狀態

下載Kafka

http://kafka.apache.org/downloads.html

 

下載二進制包

下載后解壓縮，我這里解壓縮到了 D:\WorkSoftware\kafka_2.11_0.10.1.0 目錄

 

解壓縮

 

首先建立一個空文件夾 logs

 

建立logs文件夾

進入config目錄，編輯 server.properties 文件

 

編輯server.properties

修改 log.dirs 屬性部分的地址

 

修改log.dirs屬性

 

然后在 D:\WorkSoftware\kafka_2.11_0.10.1.0 目錄，按住shift+鼠標右鍵

 

在此處打開命令窗口

然后輸入下面命令

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

 

 

回車，執行命令

 

出現錯誤

如果出現錯誤，我這里分析是CLASSPATH沒有配置正確，那么，先設置CLASSPATH，然后再執行

SET CLASSPATH=.; 

 

設置CLASSPATH

 

成功

測試一下，首先進入 D:\WorkSoftware\kafka_2.11-0.10.1.0\bin\windows 目錄，然后在當前目錄打開命令窗口

 

 

輸入下面命令，創建一個topic

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

如果還遇到無法加載類等錯誤，還是先設置CLASSPATH

 

遇到無法加載主類，需要設置CLASSPATH

 

topic創建成功

打開一個Producer

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

 

執行命令，打開生產者

這三個窗口不關閉的情況下(zookeeper/kafka/producer)，再次開啟一個命令窗口(還是在kafka目錄右鍵打開)，輸入下面命令，開啟Consumer

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

 

 

這樣，這里就有4個命令窗口

 

 

分別是

1. Zookeeper
2. Kafka
3. Producer
4. Consumer

下面，我們在3號窗口(Producer)輸入一些字符，就會看到4號窗口馬上就收到消息

 

 

至此，Kafka的Windows單機環境搭建完畢

作者：sphsyv
鏈接：https://www.jianshu.com/p/64d25dcf8300
來源：簡書
簡書著作權歸作者所有，任何形式的轉載都請聯系作者獲得授權並注明出處。