20190312 Windows安裝Kafka

1. 下載

使用版本2.1.1

官網下載地址

2. 安裝

2.1. 前提

已安裝ZooKeeper，可參考 20190311 Windows安裝ZooKeeper 進行安裝ZooKeeper

2.2. 修改config/server.properties配置文件

log.dirs=E:\\Develop\\kafka\\2.11-2.1.1\\kafka_2.11-2.1.1\\kafka-logs

2.3. 啓動ZooKeeper，成功後，啓動Kafka

第一次啓動報錯，緣由是環境變量中的JAVA_HOME中路徑中不能有空格

PS E:\Develop\kafka\2.11-2.1.1\kafka_2.11-2.1.1> .\bin\windows\kafka-server-start.bat .\config\server.properties
命令語法不正確。
錯誤: 找不到或沒法加載主類 Files\Java\jdk1.8.0_151\lib;C:\Program

我當前的JAVA_HOME是

E:\Develop\kafka\2.11-2.1.1\kafka_2.11-2.1.1>echo %JAVA_HOME%
C:\Program Files\Java\jdk1.8.0_151

修改成：

C:\Java\jdk1.8.0_151

修改後，也會提示：

命令語法不正確。

可是，確實是正常啓動。

2.4. 測試啓動成功

2.4.1. 建立一個topic

E:\Develop\kafka\2.11-2.1.1\kafka_2.11-2.1.1>  .\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
錯誤: 找不到或沒法加載主類 Files\Java\jdk1.8.0_151\lib;C:\Program

在網上查詢後，找到解決方案，修改bin/windows/kafka-run-class.bat第179行，爲%CLASSPATH%加上雙引號

set COMMAND=%JAVA% %KAFKA_HEAP_OPTS% %KAFKA_JVM_PERFORMANCE_OPTS% %KAFKA_JMX_OPTS% %KAFKA_LOG4J_OPTS% -cp "%CLASSPATH%" %KAFKA_OPTS% %*

再次運行建立命令，建立成功

E:\Develop\kafka\2.11-2.1.1\kafka_2.11-2.1.1>.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
Created topic "test".

2.4.2. 查看topic的list

E:\Develop\kafka\2.11-2.1.1\kafka_2.11-2.1.1>.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
test

2.4.3. 啓動生產者和消費者進行通訊

生產者：

E:\Develop\kafka\2.11-2.1.1\kafka_2.11-2.1.1>.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
>abcd
>xxx
>

消費者：

E:\Develop\kafka\2.11-2.1.1\kafka_2.11-2.1.1>.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
abcd
xxx

參考資料

Kafka官網