Windows平台kafka环境的搭建

注意：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发送的消息：