kafka window安裝與配置


一、安裝jdk1.8
(此處省略)

二、安裝zookeeper
1. 下載安裝包:http://zookeeper.apache.org/releases.html,解壓到指定目錄(如下)

2. 在系統變量中添加ZOOKEEPER_HOME = C:\Users\wcy\Downloads\Compressed\zookeeper-3.4.10

3. 編輯path系統變量,添加為路徑%ZOOKEEPER_HOME%\bin;

4. 將conf下“zoo_sample.cfg”重命名為“zoo.cfg”

5. 在任意文本編輯器(如notepad)中打開zoo.cfg. 找到並編輯dataDir=C:/dataDir

6. 找到並編輯dataDir=C:/dataDir

7. 打開新的cmd,輸入zkServer,運行Zookeeper。

8. 命令行提示如下:說明本地Zookeeper啟動成功

 

 

 

三、安裝kafka
1.下載 http://mirrors.shu.edu.cn/apache/kafka/1.0.0/kafka_2.11-1.0.0.tgz ,解壓為kafka_2.11-1.0.0,

2.進入Kafka配置目錄,C:\Users\wcy\Downloads\kafka_2.11-1.0.0\config ,編輯文件“server.properties” 添加自己的日記目錄:log.dirs=...   同時打開注釋 listeners=PLAINTEXT://:9092。如果Zookeeper在某些其他的機器或集群上運行,可以將“zookeeper.connect:2181”修改為自定義IP與端口。在這里使用了同一個機器,所以沒其他做修改。文件中的Kafka端口和broker.id也是可以配置的。默認設置不變。

3.在zookeeper的基礎上,運行Kafka服務 
進入Kafka安裝目錄,C:\Users\wcy\Downloads\kafka_2.11-1.0.0
切換到命令行窗口,運行kafka。 

.\bin\windows\kafka-server-start.bat .\config\server.properties

 

運行成功,會有log文件的輸出,連接zk的2181端口,啟動默認的9092端口

 

 

四、測試
A、創建主題 
1. 現在創建主題,命名為“test”,replication factor=1(因為只有1個Kafka服務器在運行)。如果集群中所運行的Kafka服務器不止1個,可以相應增加replication-factor,從而提高數據可用性和系統容錯性。

2. 在C:\Users\wcy\Downloads\kafka_2.11-1.0.0\bin\windows打開新的命令行。 

3. 輸入下面的命令,回車:kafka-topics.bat –create –zookeeper localhost:2181 –replication-factor 1 –partitions 1 –topic test 

B. 創建Producer及Consumer來測試服務器。 

1.在C:\Users\wcy\Downloads\kafka_2.11-1.0.0\bin\windows打開新的命令行。 

2.輸入以下命令,啟動producer,可以輸入消息:kafka-console-producer.bat –broker-list localhost:9092 –topic test 

3.在同樣的位置C:\Users\wcy\Downloads\kafka_2.11-1.0.0\bin\windows再次打開新的命令行。 

4.現在輸入下列命令啟動consumer,可以獲取消息:kafka-console-consumer.bat –zookeeper localhost:2181 –topic test 

5.兩個命令行窗口,producer可以輸入任何消息,consumer可以獲取消息。

 

 

 

 

 


————————————————
版權聲明:本文為CSDN博主「mazda車神」的原創文章,遵循 CC 4.0 BY-SA 版權協議,轉載請附上原文出處鏈接及本聲明。
原文鏈接:https://blog.csdn.net/weixin_40255824/article/details/80167719


免責聲明!

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



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