zookeeper + kafka windows环境单机

zookeeper-3.4.10
https://www.apache.org/dyn/closer.cgi/zookeeper/
kafka_2.11-1.0.0
http://kafka.apache.org/downloads

解压zookeeper到D盘根目录，进入conf目录，拷贝zoo_sample.cfg文件文件并重命名为zoo.cfg。
打开zoo.cfg文件，”dataDir=/tmp/zookeeper”是Linux系统下的路径配置，windows环境下修改为”dataDir=D:\zookeeper-3.4.10\data”。
进入bin文件夹

zookeeper启动.jpg zkServer.jpg

zookeeper 启动完成

解压kafka到D盘根目录，进入config文件打开 server.properties文件，修改

 log.dirs=D:\kafka_2.11-1.0.0\kafka-logs

 zookeeper.connect=localhost:2181

kafka会按照默认，在9092端口上运行，连接zookeeper的默认端口：2181

进入D:\kafka_2.11-1.0.0，按下Shift+右键，选择“打开命令窗口”选项，打开命令行，输入

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

注意：启用kafka前请确保zooKeeper实例已经准备好并开始运行(不要关闭这个命令窗口)

测试kafka
创建主题，进入D:\kafka_2.11-1.0.0，按下Shift+右键，选择“打开命令窗口”选项，打开命令行，输入

.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

注意：不要关闭窗口

创建主题.jpg

查看主题，进入D:\kafka_2.11-1.0.0，按下Shift+右键，选择“打开命令窗口”选项，打开命令行，输入

.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

注意：不要关闭窗口

查看主题.jpg

创建生产者，进入D:\kafka_2.11-1.0.0，按下Shift+右键，选择“打开命令窗口”选项，打开命令行，输入

.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test

注意：不要关闭窗口

创建生产者.jpg

创建消费者，进入D:\kafka_2.11-1.0.0，按下Shift+右键，选择“打开命令窗口”选项，打开命令行，输入

.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

创建消费者.jpg