天天看點

windows安裝zookeeper、kafka

一、安裝zookeeper

注意:安裝前需要本機把java的jdk安裝好,具體安裝步驟百度一下。

下載下傳zookeeper:http://mirrors.hust.edu.cn/apache/zookeeper/

我下載下傳的是zookeeper-3.5.2-alpha.tar.gz,解壓到E盤如下圖:

windows安裝zookeeper、kafka

将E:\work\zookeeper-3.5.2-alpha\conf檔案下的 zoo_sample.cfg 檔案名改成 zoo.cfg,用記事本打開 zoo.cfg檔案,修改dataDir的值路徑,将dataDir=/tmp/zookeeper改成dataDir=E:\work\zookeeper-3.5.2-alpha\data,data的檔案夾可以自己先建立,下圖對比:

windows安裝zookeeper、kafka
windows安裝zookeeper、kafka

還有就是添加系統變量(有些部落格沒有提到這個步驟,我是添加了)

系統變量:

ZOOKEEPER_HOME:E:\work\zookeeper-3.5.2-alpha

PATH: %ZOOKEEPER_HOME%\bin;

啟動zookeeper

 1.打開新的cmd,輸入:cd  /d  E:\work\zookeeper-3.5.2-alpha\bin

 2.在此窗台繼續輸入:zkServer.cmd  就能啟動zookeeper(圖2)

 3.檢視是否啟動,打開cmd,輸入:netstat -ano|findstr "2181"  端口查到,就說明已經啟動

windows安裝zookeeper、kafka
windows安裝zookeeper、kafka

二、安裝kafka

下載下傳位址:http://kafka.apache.org/downloads.html

将下載下傳安裝包kafka_2.12-0.10.2.0.tgz解壓到E盤,找到config檔案夾下的server.properties檔案,用記事本打開,将log.dirs的值改成log.dirs=E:\work\kafka_2.12-0.10.2.0\kafka-logs

啟動Kafka

 1.打開新的cmd,輸入:cd  /d  E:\work\kafka_2.12-0.10.2.0 

 2.在此窗台繼續輸入:.\bin\windows\kafka-server-start.bat  .\config\server.properties

如下圖:

windows安裝zookeeper、kafka
windows安裝zookeeper、kafka

建立Topic:test

 1.打開新的cmd ,輸入:cd  /d  E:\work\kafka_2.12-0.10.2.0\bin\windows

 2.在此窗台繼續輸入:kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

 3.此視窗會顯示:Created topic “test” 表示建立成功

如下圖(因為之前建立過了):

windows安裝zookeeper、kafka

建立生産者Producer 

 1.打開新的cmd ,輸入:cd  /d  E:\work\kafka_2.12-0.10.2.0\bin\windows

 2.在此窗台繼續輸入:kafka-console-producer.bat --broker-list localhost:9092 --topic test

如下圖:

windows安裝zookeeper、kafka

建立生産者Consumer 

 1.打開新的cmd ,輸入:cd  /d  E:\work\kafka_2.12-0.10.2.0\bin\windows

 2.在此窗台繼續輸入:kafka-console-consumer.bat --zookeeper localhost:2181 --topic test

如下圖:

windows安裝zookeeper、kafka

如何發送消息

 1.在建立生産者Producer視窗輸入:nihao

 2.按Enter鍵

 3.在建立生産者Consumer視窗就能收到資訊:nihao

如下圖:

windows安裝zookeeper、kafka

繼續閱讀