Kafaka在Windows環境下的部署（一）-安裝

前提：JDK已安裝

 

一、Zookeeper安裝

  官方下載地址：http://zookeeper.apache.org/releases.html#download

  1.下載完成后將安裝包解壓縮，博主是解壓縮到D:\Tool目錄下

  2.找到安裝包conf文件夾下的“zoo_sample.cfg”文件，將其重命名為“zoo.cfg”

  3.使用記事本或其他文本編輯器，打開zoo.cfg，找到dataDir，輸入數據存放路徑（自定義路徑）

  4.添加環境變量ZOOKEEPER_HOME，值為安裝包的路徑，並在Path系統變量中添加為路徑 %ZOOKEEPER_HOME%\bin

  

  5.打開cmd，輸入zkServer（成功后不要關閉）。

    PS:新版本啟動時可能會提示

  Zookeeper audit is disabled

    只要在上述zoo.cfg的文本中添加如下內容即可

    

   6.將ZOOKEEPER配置為Windows服務；

     1）下載服務插件，下載地址  http://archive.apache.org/dist/commons/daemon/binaries/windows/

    

 

     2）解壓后把prunsrv.exe、prunmgr.exe復制到zookeeper的bin路徑下

     3）bin文件夾下新建一個install.bat文件，用於注冊服務

         

prunsrv.exe "//IS//%ZOOKEEPER_SERVICE%" ^
        --DisplayName="Zookeeper (%ZOOKEEPER_SERVICE%)" ^
        --Description="Zookeeper (%ZOOKEEPER_SERVICE%)" ^
        --Startup=auto --StartMode=exe ^
        --StartPath=%ZOOKEEPER_HOME% ^
        --StartImage=%ZOOKEEPER_HOME%\bin\zkServer.cmd ^
        --StopPath=%ZOOKEEPER_HOME%\ ^
        --StopImage=%ZOOKEEPER_HOME%\bin\zkServerStop.cmd ^
        --StopMode=exe --StopTimeout=5 ^
        --LogPath=%ZOOKEEPER_HOME% --LogPrefix=zookeeper-wrapper ^
        --PidFile=zookeeper.pid --LogLevel=Info --StdOutput=auto --StdError=auto

    4）新建一個zkServerStop.cmd文件，用於停止服務。

   

@echo off
setlocal
TASKLIST /svc | findstr /c:"%ZOOKEEPER_SERVICE%" > %ZOOKEEPER_HOME%\zookeeper_svc.pid
FOR /F "tokens=2 delims= " %%G IN (%ZOOKEEPER_HOME%\zookeeper_svc.pid) DO (
    @set zkPID=%%G
)
taskkill /PID %zkPID% /T /F
del %ZOOKEEPER_HOME%/zookeeper_svc.pid
 
endlocal

  5）配置環境變量，添加ZOOKEEPER_SERVICE，值為你服務的名稱

   6）cmd以管理員定位到bin文件夾下，運行install.bat文件。

  

 

   7）驗證結果

 

二、Kafka安裝

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

    1.下載完成后，解壓縮，博主和Zookeeper一樣，也是放在了D:\Tool目錄下

    2.編輯文件Kafka配置文件，D:\Tool\kafka_2.13-3.1.0\config\server.properties，找到並編輯log.dirs=D:\Tool\kafka_2.13-3.1.0\data,(自定義路徑)

    3.打開cmd，將目標切換到 D:\Tool\kafka_2.13-3.1.0，運行.\bin\windows\kafka-server-start.bat  .\config\server.properties（PS:如果文件存放路徑過深，CMD命令行可能會出現輸入航太長的錯誤）

    

  三、結果測試

   1.創建主題：cmd，在Kafkad的安裝包路徑下輸入 .\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

   

 

   2.創建生產者：cmd，在Kafka安裝包路徑下輸入命令.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test

     並在下面彈出的輸入符后面任意輸入內容

    

   3.創建消費者：cmd，輸入命令.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

  說明Kafka安裝並運行成功！！

 

 

參考文章：https://blog.csdn.net/weixin_45746689/article/details/116717489

                  https://blog.csdn.net/qq_35461948/article/details/117772904

                  https://www.cnblogs.com/ycyzharry/p/11409698.html