windows下kafka的安裝與zookeeper的測試
阿新 • • 發佈:2019-02-07
首先搭建的方法網上就有很多了
zookeeper的安裝
1.進入Zookeeper設定目錄,筆者D:\Java\Tool\zookeeper-3.4.6\conf
2. 將“zoo_sample.cfg”重新命名為“zoo.cfg”
3. 在任意文字編輯器(如notepad)中開啟zoo.cfg
4. 找到並編輯dataDir=D:\Java\Tool\zookeeper-3.4.6\tmp
5. 與Java中的做法類似,我們在系統環境變數中新增:
a. 在系統變數中新增ZOOKEEPER_HOME = D:\Java\Tool\zookeeper-3.4.6
b. 編輯path系統變數,新增為路徑%ZOOKEEPER_HOME%\bin;
6. 在zoo.cfg檔案中修改預設的Zookeeper埠(預設埠2181)
開啟新的cmd,輸入zkServer(或者直接執行zkServer.bat),執行Zookeeper。
命令列提示如下:說明本地Zookeeper啟動成功
kafka的安裝
下載後解壓到任意一個目錄,筆者的是D:\Java\Tool\kafka_2.11-0.10.0.1
- 進入Kafka配置目錄,D:\Java\Tool\kafka_2.11-0.10.0.1
- 編輯檔案“server.properties”
- 找到並編輯log.dirs=D:\Java\Tool\kafka_2.11-0.10.0.1\kafka-log,這裡的目錄自己修改成自己喜歡的
- 找到並編輯zookeeper.connect=localhost:2181。表示本地執行
- Kafka會按照預設,在9092埠上執行,並連線zookeeper的預設埠:2181。
執行:
重要:請確保在啟動Kafka伺服器前,Zookeeper例項已經準備好並開始執行。
測試kafka與zookeeper環境
新開一個命令視窗,定為到
- kafka目錄下的\bin\windows
- 輸入命令
.\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
來建立topic 名為test。topic可以理解為一個邏輯佇列,邏輯佇列裡存放訊息的是若干個(可配置)partitions。 - 建立一個生產者和一個消費者來測試訊息
開啟兩個命令視窗, 定為到kafka安裝目錄\bin\windows,一個用於producer,另一個作為consumer
a)建立producer(視窗一)
kafka-console-producer.bat --broker-list localhost:9092 --topic test
b)建立consumer(視窗二)
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test
(zookeeper高版本需要這樣寫–bootstrap-server) - 在視窗一producer端輸入你想輸入的文字,在視窗二就顯示出了視窗一輸入的內容。說明kafka與zookeeper的整合測試成功。