1. 程式人生 > >Window上安裝配置Zookeeper和Kafka

Window上安裝配置Zookeeper和Kafka

安裝配置Zookeeper

下載zookeeper安裝包 :http://zookeeper.apache.org/doc/r3.5.4-beta/

解壓後可以看到:

將conf下的zoo-sample.cfg更名為zoo.cfg,因為剛下下來的bin/zkEnv.cmd裡面指定的配置檔案就是zoo.cfg 

conf/zoo.cfg

dataDir=D:\\zookeeper\\data
dataLogDir=D:\\zookeeper\\log
# the port at which the clients will connect
clientPort=2181
# the maximum number of client connections.
# increase this if you need to handle more clients
#maxClientCnxns=60

通過zkServer.cmd成功啟動zookeeper 

注:也可在本地配置zookeeper環境變數

開啟命令列輸入:zkserver 直接啟動zookeeper

安裝配置Kafka

1.下載https://www.apache.org/dyn/closer.cgi?path=/kafka/2.0.0/kafka_2.12-2.0.0.tgz ,解壓為kafka_2.12-2.0.0

2.進入Kafka配置目錄,kafka_2.12-2.0.0\config ,編輯檔案“server.properties” 新增自己的日記目錄:log.dirs=...   同時開啟註釋 listeners=PLAINTEXT://:9092。如果Zookeeper在某些其他的機器或叢集上執行,可以將“zookeeper.connect:2181”修改為自定義IP與埠。在這裡使用了同一個機器,所以沒其他做修改。檔案中的Kafka埠和broker.id也是可以配置的。預設設定不變。

注:日誌資料夾自己新建,我這裡是建在d盤上的

3.先執行zookeeper服務,再執行Kafka服務 
進入Kafka安裝目錄,D:\Kafka\kafka_2.12
切換到命令列視窗,執行kafka。 

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

執行成功

 

 

執行成功,會有log檔案的輸出,連線zk的2181埠,啟動預設的9092埠