一.安裝Zookeeper(Kafaka依賴於zookeeper進行服務注冊和管理)
1. 1 下載zookeeper:http://mirror.bit.edu.cn/apache/zookeeper/
1.2 解壓 zookeeper-3.4.12 到 D:\software\zookeeper-3.4.12
1.3 復制D:\software\zookeeper-3.4.12\conf\zoo_sample.cfg並命名為:zoo.cfg
1.4 修改zoo.cfg配置文件的dataDir為:D:\software\zookeeper-3.4.12\data(手動創建data文件夾),修改端口clientPort為:12181(如果2181端口未被占用,則不需要進行端口修改)
1.5 配置zookeeper的環境變量:ZOOKEEPER_HOEM=D:\software\zookeeper-3.4.12,並編輯PATH,在變量值末尾添加: ;%ZOOKEEPER_HOEM%\bin;
1.6 啟功zookeeper服務,打開cmd窗口輸入:zkServer命令啟動zookeeper服務
(無報錯信息,則說明啟動成功,圖略)
二. 安裝Kafka
2.1 下載kafka: http://kafka.apache.org/downloads.html
2.2 解壓kafka 到 D:\software\kafka_2.11-2.1.0
2.3 在kafka_2.11-2.1.0目錄下手動創建logs文件夾
2.4 修改配置文件:D:\software\kafka_2.11-2.1.0\config\server.properties中的log.dirs 為D:\software\kafka_2.11-2.1.0\logs,若zookeeper修改了默認端口,則還需要修改server.properties中zookeeper.connect 為 localhost:12181
2.5 啟動kafaf服務:進入kafa的安裝目錄,在當前目錄下新建cmd窗口:
輸入一下命令:.\bin\windows\kafka-server-start.bat .\config\server.properties
(無報錯信息,則說明啟動成功,圖略)
三. 測試
3.1 新建名稱為test 的topics ,進入D:\software\kafka_2.11-2.1.0\bin\windows\目錄,在當前目錄下新建cmd窗口,並輸入:
kafka-topics.bat --create --zookeeper localhost:12181 --replication-factor 1 --partitions 1 --topic test
3.2 新建消息生產者,進入D:\software\kafka_2.11-2.1.0\bin\windows\目錄,在當前目錄下新建cmd窗口,並輸入:
kafka-console-producer.bat --broker-list localhost:9092 --topic test
3.3 新建消息消費者, 進入D:\software\kafka_2.11-2.1.0\bin\windows\目錄,在當前目錄下新建cmd窗口,並輸入:
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test
測試結果:
在product窗口輸入的信息,同時會顯示在consumer窗口內。