Windows下安裝Kafka

1、安裝JDK

2、安裝zooeleeper

下載安裝包：http://zookeeper.apache.org/releases.html#download

下載後解壓到一個目錄：

1.進入Zookeeper設置目錄，筆者D:\Java\Tool\zookeeper-3.4.6\conf
2. 將「zoo_sample.cfg」重命名爲「zoo.cfg」
3. 在任意文本編輯器（如notepad）中打開zoo.cfg
4. 找到並編輯dataDir=D:\\Java\\Tool\\zookeeper-3.4.6\\tmp
5. 與Java中的作法相似，咱們在系統環境變量中添加：
　　a. 在系統變量中添加ZOOKEEPER_HOME = D:\Java\Tool\zookeeper-3.4.6
　　b. 編輯path系統變量，添加爲路徑%ZOOKEEPER_HOME%\bin;
6. 在zoo.cfg文件中修改默認的Zookeeper端口（默認端口2181）
7. 打開新的cmd，輸入zkServer，運行Zookeeper。
8. 命令行提示以下：說明本地Zookeeper啓動成功

 

3、安裝與運行Kafka

下載：

http://kafka.apache.org/downloads.html。注意要下載二進制版本的

下載後解壓到任意一個目錄F:/kafka_2.11-0.10.0.1

1. 進入Kafka配置目錄，F:/kafka_2.11-0.10.0.1
2. 編輯文件「server.properties」
3. 找到並編輯log.dirs=F:/kafka_2.11-0.10.0.1/kafka-log,這裏的目錄本身修改爲本身喜歡的
4. 找到並編輯zookeeper.connect=localhost:2181。表示本地運行
5. Kafka會按照默認，在9092端口上運行，並鏈接zookeeper的默認端口：2181。

運行：

重要：請確保在啓動Kafka服務器前，Zookeeper實例已經準備好並開始運行。

1.進入Kafka安裝目錄F:/kafka_2.11-0.10.0.1
2.按下Shift+右鍵，選擇「打開命令窗口」選項，打開命令行。
3.如今輸入

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

並回車

 

4、測試（上面的Zookeeper和kafka一直打開）

（1）、建立主題

1.進入Kafka安裝目錄D:\Java\Tool\kafka_2.11-0.10.0.1
2.按下Shift+右鍵，選擇「打開命令窗口」選項，打開命令行。
3.如今輸入

./bin/windows/kafka-console-consumer.bat --zookeeper localhost:2181 --topic helloworld

並回車

（2）建立生產者

1.進入Kafka安裝目錄D:\Java\Tool\kafka_2.11-0.10.0.1
2.按下Shift+右鍵，選擇「打開命令窗口」選項，打開命令行。
3.如今輸入

./bin/windows/kafka-console-producer.bat --broker-list localhost:9092 --topic helloworld

並回車

（3）建立消費者

1.進入Kafka安裝目錄D:\Java\Tool\kafka_2.11-0.10.0.1
2.按下Shift+右鍵，選擇「打開命令窗口」選項，打開命令行。
3.如今輸入

./bin/windows/kafka-console-consumer.bat --zookeeper localhost:2181 --topic helloworld

並回車

而後在生產者窗口中輸入內容並回車，便可在消費者窗口看到消息。