WINDOWS上KAFKA運行環境安裝

1. 安裝JDK

1.1 安裝文件：http://www.oracle.com/technetwork/java/javase/downloads/index.html 下載JDK
1.2 安裝完成后需要添加以下的環境變量（右鍵點擊“我的電腦” -> "高級系統設置" -> "環境變量"?）：

• JAVA_HOME:?C:\Program Files\Java\jdk1.8.0_171 (jdk的安裝路徑)

• Path: 在現有的值后面添加"; %JAVA_HOME%\bin"

1.3 打開cmd運行 "java -version" 查看當前系統Java的版本：

2. 安裝ZOOKEEPER

Kafka的運行依賴于Zookeeper，所以在運行Kafka之前我們需要安裝并運行Zookeeper

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

2.2 解壓文件?

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

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

2.5 把dataDir的值改成“./zookeeper-3.4.13/data”

2.6 添加如下系統變量：

• ZOOKEEPER_HOME: C:\Users\localadmin\CODE\zookeeper-3.4.13 (zookeeper目錄)
• Path: 在現有的值后面添加 ";%ZOOKEEPER_HOME%\bin;"

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

cmd 窗口不要關閉

3. 安裝并運行KAFKA

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

3.2 解壓文件

3.3 打開kafka_2.11-2.0.0\config

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

3.5 把 log.dirs的值改成?“./logs”

3.6 打開cmd

3.7 進入kafka文件目錄: cd?C:\Users\localadmin\CODE\kafka_2.11-2.0.0(kafka目錄)

3.8 輸入并執行:? .\bin\windows\kafka-server-start.bat .\config\server.properties

cmd 窗口不要關閉

4. 創建TOPICS

4.1 打開cmd 并進入cd?C:\Users\localadmin\CODE\kafka_2.11-2.0.0\bin\windows

4.2 創建一個topic：?kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

5. 打開一個PRODUCER：

cd C:\Users\localadmin\CODE\kafka_2.11-2.0.0\bin\windows

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

6. 打開一個CONSUMER:

cd?C:\Users\localadmin\CODE\kafka_2.11-2.0.0\bin\windows

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

7. 測試:

?

本文版權歸作者和博客園共有，歡迎轉載，但未經作者同意需保留此段聲明，且在文章頁面明顯位置給出原文連接。https://www.cnblogs.com/lnice/p/9668750.html