kafka依赖zookeeper,所以先安装zookeeper

zookeeper

1、 下载zookeeper

http://zookeeper.apache.org/releases.html#download

2、解压
到conf目录下,复制zoo_sample.cfg 重命名为zoo.cfg
3、修改zoo.cfg
更改以下项即可

dataDir=/tmp/zookeeper
clientPort=2181

4、启动zookeeper
到bin目录下 双击zkServer.cmd。或者bin目录下打开cmd窗口，运行zkServer.cmd

kafka

1、下载

http://kafka.apache.org/downloads

2、解压
到conf目录下

修改server.properties 主要是zookeeper链接地址

./logs=D:\otherTools\kafkalogs\logs
zookeeper.connect=localhost:2181

修改zookeeper.properties

dataDir=/tmp/zookeeper
clientPort=2181

3、启动kafka
kafka目录下打开cmd窗口输入以下命令 (以server.properties配置启动)

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

以上，zk kafka已经启动成功！

测试

1、进入kafka/bin/windows 目录打开cmd窗口，输入命令创建topic

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

2、kafka/bin/windows 目录重新打开cmd窗口
创建生产者

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

3、kafka/bin/windows 目录重新打开cmd窗口
创建消费者

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic testDemo

4、生产者发送消息–消费者消费