windows環境下配置Kafaka


一.安裝Zookeeper(Kafaka依賴於zookeeper進行服務注冊和管理)

1. 1   下載zookeeper:http://mirror.bit.edu.cn/apache/zookeeper/ 

1.2     解壓 zookeeper-3.4.12 到 D:\software\zookeeper-3.4.12

1.3   復制D:\software\zookeeper-3.4.12\conf\zoo_sample.cfg並命名為:zoo.cfg

1.4   修改zoo.cfg配置文件的dataDir為:D:\software\zookeeper-3.4.12\data(手動創建data文件夾),修改端口clientPort為:12181(如果2181端口未被占用,則不需要進行端口修改)

1.5    配置zookeeper的環境變量:ZOOKEEPER_HOEM=D:\software\zookeeper-3.4.12,並編輯PATH,在變量值末尾添加: ;%ZOOKEEPER_HOEM%\bin;

1.6  啟功zookeeper服務,打開cmd窗口輸入:zkServer命令啟動zookeeper服務

(無報錯信息,則說明啟動成功,圖略)

二. 安裝Kafka

2.1  下載kafka: http://kafka.apache.org/downloads.html 

2.2   解壓kafka 到 D:\software\kafka_2.11-2.1.0

2.3   在kafka_2.11-2.1.0目錄下手動創建logs文件夾

2.4   修改配置文件:D:\software\kafka_2.11-2.1.0\config\server.properties中的log.dirs 為D:\software\kafka_2.11-2.1.0\logs,若zookeeper修改了默認端口,則還需要修改server.properties中zookeeper.connect 為 localhost:12181

2.5    啟動kafaf服務:進入kafa的安裝目錄,在當前目錄下新建cmd窗口:

輸入一下命令:.\bin\windows\kafka-server-start.bat .\config\server.properties

(無報錯信息,則說明啟動成功,圖略)

三. 測試

3.1  新建名稱為test 的topics ,進入D:\software\kafka_2.11-2.1.0\bin\windows\目錄,在當前目錄下新建cmd窗口,並輸入:

  kafka-topics.bat --create --zookeeper localhost:12181 --replication-factor 1 --partitions 1 --topic test

3.2 新建消息生產者,進入D:\software\kafka_2.11-2.1.0\bin\windows\目錄,在當前目錄下新建cmd窗口,並輸入:

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

3.3   新建消息消費者, 進入D:\software\kafka_2.11-2.1.0\bin\windows\目錄,在當前目錄下新建cmd窗口,並輸入:

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

測試結果:

  在product窗口輸入的信息,同時會顯示在consumer窗口內。

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM