1. 程式人生 > >windows10下Kafka環境搭建

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

        

6)    搭建成功。
--------------------- 
作者:tianmanchn 
來源:CSDN 
原文:https://blog.csdn.net/tianmanchn/article/details/78943147 
版權宣告:本文為博主原創文章,轉載請附上博文連結!