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
