實驗平臺與軟件：

操作系統：windows7 32 位

java 開發包: jdk1.8.0_144

集群: zookeeper-3.3.6

消息隊列: kafka_2.11-0.11.0.1

安裝序列：

1. jdk安裝預配置

jdk-8u144-windows-i586_8.0.1440.1.exe

點擊安裝："下一步" ...

環境變量配置：

1）計算機/屬性/高級系統設置/高級/環境變量，在系統變量中新建變量：JAVA_HOME 值：C:\Program

Files\Java\jdk1.8.0_144(根據安裝路徑調整)

2）再新建變量:Classpath ,值：.;%JAVA_HOME%\lib;%JAVA_HOME%\lib\tools.jar

3）最後在系統變量：Path 的值後加上： %JAVA_HOME%\bin;%JAVA_HOME%\jre\bin;

測試

打開CMD命令窗口輸入：java -version

回車執行，如果能正常顯示java版本 說明安裝配置成功

註意：

1）多個環境變量值之間需用分號隔開

2）Classpath值前面有一小點

2. zookeeper 安裝配置

1）壓縮包解壓：zookeeper-3.3.6

2）目錄下新建data 文件夾

3）conf目錄，然後復制zoo_sample.cfg為zoo.cfg

4）修改zoo.cfg 中的dataDir=D:\zookeeper-3.3.6\zookeeper-3.3.6\data

(根據解壓路徑做相應調整)

3.啟動zookeeper

進入 bin 目錄，執行 zkServer.cmd

在bin目錄 :shift + 鼠標右鍵 -> 打開命令窗口

輸入：zkServer.cmd 回車執行

4 kafka配置

壓縮包解壓：D:\kafka_2.11-0.11.0.1

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

log.dirs=D:\kafka_2.11-0.11.0.1\logs

在路徑D:\kafka_2.11-0.11.0.1下執行CMD命令：

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


在路徑bin\window下
1）創建 topic  :

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

2) 創建 producer:

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

3) 創建 consummer:

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

5 測試
下面，我們在窗口(Producer)輸入一些字符，就會看到consummer窗口馬上就收到消息。

windows下kafka配置入門 示例