前言：
需要你的电脑本地环境装有Java jdk
一、安装Zookeeper
1、官网下载安装包
地址：http://zookeeper.apache.org/releases.html#download
选择任意一个版本
点击链接即可下载
2、解压文件 进入conf目录 D:\codeapp\apache-zookeeper-3.7.0-bin\conf
3、复制"zoo_sample.cfg”文件并重命名为“zoo.cfg”
4、打开"zoo.cfg" 配置
dataDir=D:\codeapp\apache-zookeeper-3.7.0-bin\data
dataLogDir=D:\codeapp\apache-zookeeper-3.7.0-bin\log
在D:\codeapp\apache-zookeeper-3.7.0-bin目录下新建data文件和log文件
5、添加系统变量 ：ZOOKEEPER_HOME =D:\codeapp\apache-zookeeper-3.7.0-bin
在path变量下添加 %ZOOKEEPER_HOME%\bin
6、打开CMD 输入命令 zkServer 运行Zookeeper
启动成功 窗口保持运行
二、安装Kafka
1、进入官网下载安装包 http://kafka.apache.org/downloads
点击链接进行下载
2、解压并进入config目录，D:\codeapp\kafka_2.13-2.8.0\config
3、打开server.properties编辑以下属性
log.dirs=D:\\codeapp\\kafka_2.13-2.8.0\\kafka-logs
zookeeper.connect=localhost:2181
注意分隔符是\\
4、打开zookeeper.properties文件编辑以下属性
dataDir=D:\\codeapp\\apache-zookeeper-3.7.0-bin\\data
#路径为你的zookeeper安装目录下的data文件
在主目录D:\codeapp\kafka_2.13-2.8.0 新建文件夹kafka-logs
5、进入Kafka主目录 D:\codeapp\kafka_2.13-2.8.0 地址栏输入cmd回车打开cmd窗口
输入命令
start bin\windows\kafka-server-start.bat config\server.properties
不要关闭这个窗口
三、测试
1、创建topic
不要关闭以上两个cmd窗口 进入D:\codeapp\kafka_2.13-2.8.0主目录 重新打开一个cmd窗口
输入以下命令创建一个topic
bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kafka-test
创建成功
2、查看已创建的topic，刚刚创建的名为 kafka-test
bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
3、新建生产者Producer
进入进入D:\codeapp\kafka_2.13-2.8.0主目录 重新打开一个cmd窗口 输入以下命令
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic kafka-test
输入几段消息
4、新建消费者Consumer
进入进入D:\codeapp\kafka_2.13-2.8.0主目录 重新打开一个cmd窗口 输入以下命令
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kafka-test --from-beginning
刚才输入的消息也能够看得到
生产者输入的消息 消费者端也能够快速看到
参考资料：
