一、安裝zookeeper
注意:安裝前需要本機把java的jdk安裝好,具體安裝步驟百度一下。
下載下傳zookeeper:http://mirrors.hust.edu.cn/apache/zookeeper/
我下載下傳的是zookeeper-3.5.2-alpha.tar.gz,解壓到E盤如下圖:

将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的檔案夾可以自己先建立,下圖對比:
還有就是添加系統變量(有些部落格沒有提到這個步驟,我是添加了)
系統變量:
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" 端口查到,就說明已經啟動
二、安裝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
如下圖:
建立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” 表示建立成功
如下圖(因為之前建立過了):
建立生産者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
如下圖:
建立生産者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
如下圖:
如何發送消息
1.在建立生産者Producer視窗輸入:nihao
2.按Enter鍵
3.在建立生産者Consumer視窗就能收到資訊:nihao
如下圖: