一，安装JAVA JDK
二，安装ZooKeeper
2，解压并进入ZooKeeper目录，如：F:\kafka\zookeeper_core\apache-zookeeper-3.6.2-bin\conf
3，将“zoo_sample.cfg”重命名为“zoo.cfg”
4,打开“zoo.cfg”找到并编辑dataDir=F:\\kafka\\zookeeper_core\\snapshot(必须以\\分割)
5,添加系统变量:ZOOKEEPER_HOME = F:\kafka\zookeeper_core\apache-zookeeper-3.6.2-bin
6,编辑path系统变量，添加路径:%ZOOKEEPER_HOME%\bin
7，打开cmd，输入“z'kServer”,运行Zookeeper,如下图所示
不要关闭该窗口
三，安装Kafka
1,下载安装包：http://kafka.apache.org/downloads，下载二进制版本
2，解压并进入Kafka目录，F:\kafka\kafka_core\kafka_2.13-2.6.0
3，进入config目录找到文件server.propertes并打开
4，找到并编辑log.dirs=F:\kafka\kafka_core\kafka_2.13-2.6.0\kafka-logs
5，找到并编辑zookeeper.connect=localhost:2181
6，Kafka会按照默认，在9092端口上运行，并连接zookeeper的默认接口，：2181
7，进入Kafka安装目录F:\kafka\kafka_core\kafka_2.13-2.6.0，打开命令窗口，输入命令
.\bin\windows\kafka-server-start.bat .\config\server.properties
或bin\kafka-server-start.sh config\server.properties
不要关闭该窗口
四，测试
1，创建主题：进入kafka安装目录：F:\kafka\kafka_core\kafka_2.13-2.6.0，打开命令窗口，输入命令
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
不要关闭该窗口
查看主题输入
.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
3，创建生产者，打开命令窗口，进入kafka安装目录，输入命令
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
不要关闭该窗口
4，创建消费者，打开命令窗口，进入kafka安装目录，输入
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
此时，往生产者窗口写入消息，消费者窗口也能同步接收消息
5，查看topic,打开命令窗口，进入kafka安装目录，输入命令
.\bin\windows\kafka-topics.bat --describe --zookeeper localhost:2181 --topic
test
参考连接：https://blog.csdn.net/weixin_38004638/article/details/91893910