準(zhǔn)備工作

1. Java環(huán)境
2. Kafka安裝包（已包含zookeeper）

安裝步驟

1 Java安裝

自行百度

2 下載、安裝Kafka

1. 打開 下載地址

2. 選擇下圖紅框中的版本，Kafka包名組成： Scala版本 - Kafka自身版本

   
   
   下載頁

3. 下載完成之后解壓，目錄如下圖：

   
   

3 啟動(dòng)服務(wù)

3.1 啟動(dòng)ZooKeeper

打開kafka_2.12-2.1.0\bin\windows目錄，該目錄下是所有windows命令：

在此目錄下打開cmd，執(zhí)行命令zookeeper-server-start.bat ..\..\config\zookeeper.properties，如下圖：

3.2 啟動(dòng)Kafka

依舊在目錄下打開cmd，執(zhí)行命令kafka-server-start.bat ..\..\config\server.properties，如下圖：

OK，啟動(dòng)成功。
注意：
如果出現(xiàn)‘命令語法不正確’ ，導(dǎo)致不能正常運(yùn)行，嘗試修改配置文件的dataDir（zookeeper.properties），log.dirs（server.properties）。因?yàn)槟J(rèn)的是linux的文件目錄格式。

4 測試Kafka命令

• 創(chuàng)建一個(gè)主題
  kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kafka-test-topic
• 查看創(chuàng)建的主題列表
  kafka-topics.bat --list --zookeeper localhost:2181

執(zhí)行完上面兩條命令后如下圖：

• 啟動(dòng)生產(chǎn)者：
  kafka-console-producer.bat --broker-list localhost:9092 --topic kafka-test-topic
  此時(shí)可以從控制臺(tái)輸入信息，待消費(fèi)者啟動(dòng)后可接收到生產(chǎn)者發(fā)布的消息。
  

• 啟動(dòng)消費(fèi)者：
  kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kafka-test-topic --from-beginning
  此時(shí)便能看到發(fā)布出去的消息了