PE 執行命令 per ofo lec files orien cati www.

首先確保機器已經安裝好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
來源：簡書
簡書著作權歸作者所有，任何形式的轉載都請聯系作者獲得授權並註明出處。

Windows單機配置Kafka環境