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 ....configzookeeper.properties
2）、启动kafka
kafka-server-start.bat ....configserver.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
