Windows下安裝Kafka

1 安裝JDK

參考Java環境變量配置

2 安裝Zookeeper

2.1  下載安裝文件： http://zookeeper.apache.org/releases.html

2.2  解壓文件到D:\Program Files\zookeeper-3.4.14

2.3  打開zookeeper-3.4.14\conf，把zoo_sample.cfg重命名成zoo.cfg

2.4  在文本編輯器里打開zoo.cfg

2.5  把dataDir的值改成如下：

dataDir=D:/Program Files/zookeeper-3.4.14/data

2.6  添加如下系統變量：

• 在系統變量中添加ZOOKEEPER_HOME 值為D:\Program Files\zookeeper-3.4.14
• 編輯Path：在現有的值后面添加 ;%ZOOKEEPER_HOME%\bin;

2.7 運行Zookeeper：打開cmd然后執行zkserver

注意，cmd窗口不要關閉。

3 安裝Kafka

3.1 下載安裝文件：  http://kafka.apache.org/downloads.html

3.2  解壓文件到D:\kafka_2.12-2.3.0

3.3  打開kafka_2.12-2.3.0\config

3.4  在文本編輯器里打開 server.properties

3.5  把 log.dirs的值改成如下：

log.dirs=D:/kafka_2.12-2.3.0/kafka-logs

3.6  打開cmd，進入kafka文件目錄: cd D:\kafka_2.12-2.3.0

3.7  輸入並執行：

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

注意，cmd窗口不要關閉。

 

4 創建topic

4.1 打開cmd，進入cd D:\kafka_2.12-2.3.0\bin\windows

4.2 創建一個topic：

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

5 創建producer

5.1 打開cmd，進入cd D:\kafka_2.12-2.3.0\bin\windows

5.2 啟動producer：

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

6 創建consumer

6.1 打開cmd，進入cd D:\kafka_2.12-2.3.0\bin\windows

6.2 啟動consumer：

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

7 測試

在producer命令行中任意輸入內容，回車；在其他consumer命令行中能看到相應消息。

8 其他命令

8.1 列出主題

kafka-topics.bat --list --zookeeper localhost:2181

8.2 描述主題

kafka-topics.bat --describe --zookeeper localhost:2181 --topic [Topic Name]

8.3 從頭讀取消息

kafka-console-consumer.bat --bootstrap-server localhost:2181 --topic [Topic Name] --from-beginning

8.4 刪除主題

kafka-run-class.bat kafka.admin.TopicCommand --delete --topic [topic_to_delete] --zookeeper localhost:2181

參考  Setting Up and Running Apache Kafka on Windows OS