注意：Kafka的运行依赖于Zookeeper，所以在运行Kafka之前我们需要安装并运行Zookeeper
下载安装文件： http://kafka.apache.org/downloads.html
1 解压文件（本文解压到 D:\kafka_2.9.2-0.8.2.2）
2 打开D:\kafka_2.9.2-0.8.2.2\config\ server.properties
3 把 log.dirs的值改成 log.dirs=D:\data\logs\kafka
4 D:\kafka_2.9.2-0.8.2.2\bin文件夹下的.sh命令脚本是在shell下运行的，此文件夹下还有个 windows文件夹，里面是windows下运行的.bat命令脚本
5 在D:\kafka_2.9.2-0.8.2.2文件夹中”Shift+鼠标右键”点击空白处打开命令提示窗口
6 输入并执行一下命令以打开kafka:
.\bin\windows\kafka-server-start.bat .\config\server.properties
如果运行提示java内存不够之类的：
可以修改kafka-server-start.bat里面的配置。
一般都需要去掉kafka-run-class.bat里面的 -XX:+UseCompressedOops 才能运行。
7.创建topics
7.1在D:\kafka_2.9.2-0.8.2.2\bin\windows文件夹中”Shift+鼠标右键”点击空白处打开命令提示窗口
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
8.打开一个Producer
8.1在D:\kafka_2.9.2-0.8.2.2\bin\windows文件夹中”Shift+鼠标右键”点击空白处打开命令提示窗口
kafka-console-producer.bat --broker-list localhost:9092 --topic test
9.打开一个Consumer
9.1在D:\kafka_2.9.2-0.8.2.2\bin\windows文件夹中”Shift+鼠标右键”点击空白处打开命令提示窗口
kafka-console-consumer.bat --zookeeper localhost:2181 --topic test
注意：以上打开的窗口不要关闭
然后就可以在Producer控制台窗口输入消息了。在消息输入过后，很快Consumer窗口就会显示出Producer发送的消息：
