windows 下 kafka安裝與使用

②將"zoo_sample.cfg"重新命名為"zoo.cfg"

datadir=/tmp/zookeeper to d:/bigdata/zookeeper-3.4.10/data或 d:\bigdata\zookeeper-3.4.10\data(路徑僅為示例，具體可根據需要配置)

這裡注意，路徑要麼是"/「分割，要麼是轉義字元」\"，這樣會生成正確的路徑(層級，子目錄)。

④與配置jre類似，在系統環境變數中新增：

a.系統變數中新增zookeeper_home=d:\bigdata\zookeeper-3.4.10

b.編輯系統變數中的path變數，增加%zookeeper_home%\bin

⑤在zoo.cfg檔案中修改預設的zookeeper埠(預設埠2181)

恭喜，zookeeper已經安裝完成，已在2181埠執行。

①進入kafka配置檔案所在目錄，d:\bigdata\kafka_2.11-0.9.0.1\config

log.dirs=/tmp/kafka-logs to log.dirs=d:/bigdata/kafka_2.11-0.9.0.1/kafka-logs 或者 d:\bigdata\kafka_2.11-0.9.0.1\kafka-logs

同樣注意：路徑要麼是"/「分割，要麼是轉義字元」\"，這樣會生成正確的路徑(層級，子目錄)。錯誤路徑情況可自行嘗試，資料夾名為這種形式：bigdatakafka_2.11-0.9.0.1kafka-logs

③在server.properties檔案中，zookeeper.connect=localhost:2181代表kafka所連線的zookeeper所在的伺服器ip以及埠，可根據需要更改。本文在同一臺機器上使用，故不用修改。

④kafka會按照預設配置，在9092埠上執行，並連線zookeeper的預設埠2181。

①進入kafka安裝目錄d:\bigdata\kafka_2.11-0.9.0.1

②按下shift+滑鼠右鍵，選擇"在此處開啟命令視窗"，開啟命令列。

③在命令列中輸入：.\bin\windows\kafka-server-start.bat .\config\server.properties 回車。

④正確執行的情況為：

到目前為止，zookeeper以及kafka都已正確執行。保持執行狀態，不要關閉。

依舊在目錄下開啟cmd，執行命令kafka-server-start.bat …\config\server.properties

建立乙個主題

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic hao

檢視建立的主題列表

kafka-topics.bat --list --zookeeper localhost:2181

kafka-console-producer.bat --broker-list localhost:9092 --topic hao

此時可以從控制台輸入資訊，待消費者啟動後可接收到生產者發布的訊息。

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic hao --from-beginning

此時便能看到發布出去的訊息了