windows環境下配置Kafaka

一.安裝Zookeeper(Kafaka依賴於zookeeper進行服務註冊和管理)

1. 1   下載zookeeper：http://mirror.bit.edu.cn/apache/zookeeper/ 

1.2     解壓 zookeeper-3.4.12 到 D:\software\zookeeper-3.4.12

1.3 　 複製D:\software\zookeeper-3.4.12\conf\zoo_sample.cfg並命名爲：zoo.cfg

1.4　  修改zoo.cfg配置文件的dataDir爲：D:\software\zookeeper-3.4.12\data（手動建立data文件夾），修改端口clientPort爲:12181（若是2181端口未被佔用，則不須要進行端口修改)

1.5 　  配置zookeeper的環境變量：ZOOKEEPER_HOEM=D:\software\zookeeper-3.4.12,並編輯PATH，在變量值末尾添加: ;%ZOOKEEPER_HOEM%\bin;

1.6 　啓功zookeeper服務，打開cmd窗口輸入：zkServer命令啓動zookeeper服務

（無報錯信息，則說明啓動成功，圖略）

二. 安裝Kafka

2.1 　下載kafka: http://kafka.apache.org/downloads.html 

2.2　  解壓kafka 到 D:\software\kafka_2.11-2.1.0

2.3　  在kafka_2.11-2.1.0目錄下手動建立logs文件夾

2.4　  修改配置文件：D:\software\kafka_2.11-2.1.0\config\server.properties中的log.dirs 爲D:\software\kafka_2.11-2.1.0\logs，若zookeeper修改了默認端口，則還須要修改server.properties中zookeeper.connect 爲 localhost:12181

2.5 　  啓動kafaf服務：進入kafa的安裝目錄，在當前目錄下新建cmd窗口：

輸入一下命令：.\bin\windows\kafka-server-start.bat .\config\server.properties

（無報錯信息，則說明啓動成功，圖略）

三. 測試

3.1　 新建名稱爲test 的topics ，進入D:\software\kafka_2.11-2.1.0\bin\windows\目錄，在當前目錄下新建cmd窗口，並輸入：

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

3.2　新建消息生產者，進入D:\software\kafka_2.11-2.1.0\bin\windows\目錄，在當前目錄下新建cmd窗口，並輸入：

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

3.3   新建消息消費者, 進入D:\software\kafka_2.11-2.1.0\bin\windows\目錄，在當前目錄下新建cmd窗口，並輸入：

　　kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test

測試結果：

　　在product窗口輸入的信息，同時會顯示在consumer窗口內。