kafka依赖zookeeper,所以先安装zookeeper
zookeeper1、 下载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
1、下载
http://kafka.apache.org/downloads
2、解压
到conf目录下
修改server.properties 主要是zookeeper链接地址
./logs=D:otherToolskafkalogslogs zookeeper.connect=localhost:2181
修改zookeeper.properties
dataDir=/tmp/zookeeper clientPort=2181
3、启动kafka
kafka目录下打开cmd窗口输入以下命令 (以server.properties配置启动)
.binwindowskafka-server-start.bat .configserver.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、生产者发送消息–消费者消费
