1、環境準備

jdk8
kafka_2.12-2.1.1（已包含了zookeeper，無需自行下載zk也無需安裝）

2、下載kafka，本文采用的是：Scala 2.12 -kafka_2.12-2.1.1.tgz(asc,sha512)，使用7zip或winrar解壓即可。解壓後目錄如下：

3、配置

此處，注意是正斜槓（/），不要使用反斜槓（\）。

4、啟動

1）、啟動zk：在當前目錄下開啟dos視窗，並執行如下命令：

zookeeper-server-start.bat ..\..\config\zookeeper.properties

2）、啟動kafka

kafka-server-start.bat ..\..\config\server.properties

5、測試

1）、建立主題

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

2）、檢視建立的主題

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

3）、啟動生產者

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

此時，可輸入任意字元，等消費者啟動後，就能收到了。

4）、啟動消費者

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