1. 官网下载 如：kafka_2.13-2.4.0.tgz

   新版集成了Zookeeper ,无需另行下载

2. 解压 至D:\Kafka\kafka_2.13-2.4.0 下

3. 配置Kafka（可跳过）

   • Zookeeper配置
     kafka\config\zookeeper.properties下修改dataDir路径(Zookeeper数据目录)

     dataDir=D:\\ProgramFiles\\kafka\\data\\zookeeper 

   • Kafka Broker配置
     kafka\config\server.properties下指定日志目录

     log.dirs=D:\\ProgramFiles\\kafka\\logs 

4. 启动服务

   运行需要JDK

   cd .\app\kafka_2.13-3.7.1\bin\windows # 启动 Zookeeper 服务, 默认端口 2181 .\zookeeper-server-start.bat ..\..\config\zookeeper.properties # 启动 Kafka 服务,默认端口 9092 .\kafka-server-start.bat ..\..\config\server.properties 

# 创建 Topic bin\windows\kafka-topics.bat --create --bootstrap-server localhost:2181 --replication-factor 1 --partitions 1 --topic test # 该命令 表示创建一个 名为 test 的主题，1 个副本，1个分区 

# 启动生产者 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