windows10下Kafka環境搭建

內容小白，包含JDK+Zookeeper+Kafka三部分。
JDK：
1)   安裝包：Java SE Development Kit 9.0.1
      下載地址：http://www.oracle.com/technetwork/java/javase/downloads/jdk9-downloads-3848520.html

 

2)    配置環境：（與以前版本設置有差別）

       

 

       

        

 

3)    打開Dos界面，運行java：

       

 

4)    運行javac：             

           

 

5)    配置完成。

Zookeeper：
1)    建議下載穩定版。

       下載地址：http://mirrors.hust.edu.cn/apache/zookeeper/

       

2)    下載後解壓到一個目錄：eg: D:\Java\Tool\zookeeper-3.4.10

 

3)    在zookeeper-3.4.10目錄下，新建文件夾，並命名(eg: data).(路徑爲：D:\Java\Tool\zookeeper-3.4.10\conf\data)

 

4)    進入Zookeeper設置目錄，eg: D:\Java\Tool\zookeeper-3.4.10\conf

       複製「zoo_sample.cfg」副本à並將副本重命名爲「zoo.cfg」

       在任意文本編輯器（eg：記事本）中打開zoo.cfg

       找到並編輯dataDir=D:\\Java\\Tool\\zookeeper-3.4.10\\data

 

5)    添加系統環境變量：

       在系統變量中添加ZOOKEEPER_HOME = D:\Java\Tool\zookeeper-3.4.10

       編輯path系統變量，添加爲路徑%ZOOKEEPER_HOME%\bin

 

6)    在zoo.cfg文件中修改默認的Zookeeper端口（默認端口2181）

 

7)    Dos下運行：zkserver

        

8)    搭建成功。

Kafka：
1)    安裝包：kafka_2.12-1.0.0.tgz

       下載地址：http://kafka.apache.org/downloads.html

       推薦版本：kafka_2.12-1.0.0.tgz

          

2)    下載後解壓縮。eg: D:\Tools\kafka_2.11-1.0.0\

 

3)    創建一個空文件夾 logs. eg: D:\Tools\kafka_2.11-1.0.0\logs

 

4)    進入config目錄，編輯 server.properties文件(eg: 用「寫字板」打開)。

       找到並編輯log.dirs= D:\\Tools\\kafka_2.11-1.0.0\\logs

       找到並編輯zookeeper.connect=localhost:2181。表示本地運行。

       (Kafka會按照默認，在9092端口上運行，並鏈接zookeeper的默認端口：2181)

 

運行：請確保在啓動Kafka服務器前，Zookeeper實例已經準備好並開始運行。（就是開着Zookeeper窗口不要關）

1)    在 D:\WorkSoftware\kafka_2.11-1.0.0下，按住shift+鼠標右鍵。

       選擇「在此處打開Powershell窗口（S）」（若是沒有此選項，在此處打開命令窗口）。

 

2)    運行：.\bin\windows\kafka-server-start.bat .\config\server.properties

 

3)    可能會報錯：「找不到或沒法加載主類 Files\java\jdk-9.0.1\lib;C:\Program」

        

 

4)    解決（3）的辦法：

       在kafka安裝目錄中找到bin\windows目錄中的kafka-run-class.bat爲%CLASSPATH%加上雙引號(可用Matlab打開，並進行搜索)

       修改前：setCOMMAND=%JAVA%%KAFKA_HEAP_OPTS% %KAFKA_JVM_PERFORMANCE_OPTS% %KAFKA_JMX_OPTS%%KAFKA_LOG4J_OPTS% -cp%CLASSPATH% %KAFKA_OPTS% %*   

       修改後：SetCOMMAND=%JAVA%%KAFKA_HEAP_OPTS% %KAFKA_JVM_PERFORMANCE_OPTS% %KAFKA_JMX_OPTS%%KAFKA_LOG4J_OPTS% -cp"%CLASSPATH%"%KAFKA_OPTS% %*

 

5)    再次運行：.\bin\windows\kafka-server-start.bat.\config\server.properties