一安装JAVA JDK（略）

二安装ZooKeeper

下载安装包，建议bin版本

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

解压并进入ZooKeeper，将“zoo_sample.cfg”重命名为“zoo.cfg”

D:\Kafka\apache-zookeeper-3.7.1-bin\conf

打开“zoo.cfg”并编辑

dataDir=D:\\Kafka\\apache-zookeeper-3.7.1-bin\\data 
dataLogDir=D:\\Kafka\\apache-zookeeper-3.7.1-bin\\log

添加系统变量：ZOOKEEPER_HOME=D:\Kafka\apache-zookeeper-3.7.1-bin编辑path系统变量：%ZOOKEEPER_HOME%\bin

打开新的cmd，输入“zkServer“，运行Zookeeper

本地Zookeeper启动成功

问题：ZooKeeper audit is disabled.

解决方法：在zoo.cfg中添加

audit.enabled = true

三安装Kafka

下载安装包，建议下载bin版本

http://kafka.apache.org/downloads

解压并进入Kafka编辑server.properties

D:\Kafka\kafka_2.13-3.3.2\config

编辑log.dirs=D:/Kafka/kafka_2.13-3.3.2/kafka-logs

选择“打开命令窗口”选项，D:/Kafka/kafka_2.13-3.3.2下，输入：

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

创建topic

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

查看topic

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

生产者往topic中发消息

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

消费者

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

问题：zookeeper is not a recognized option（版本原因）

解决方法：zookeeper改bootstrap-server

启动kafka

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

创建topic

.\bin\windows\kafka-topics.bat --create --topic topic-test --bootstrap-server localhost:9092

生产者往topic中发消息

.\bin\windows\kafka-console-producer.bat --topic topic-test --bootstrap-server localhost:9092

消费者接受消息

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