Windows 下 Kafka 安装教程

一、准备工作

✅ 1. 安装 Java JDK（Kafka 依赖 Java 运行环境）

Kafka 是基于 Java 的，必须先安装 JDK。一般学到kafka的同学肯定已经安装好了JDK了，这一步我就不写了，具体可以参考其他文章。

⚠️ 注意：Kafka 3.9.0 要求本地必须安装 JDK 17 或以上版本。JDK 8 和 11 已不再被官方支持。

步骤：

1. 访问官网下载 OpenJDK 或 Oracle JDK。

2. 推荐版本：JDK 8 ~ JDK 17（Kafka 3.x 支持到 JDK 17）

   

   Kafka需要的JDK版本！

3. 安装完成后设置环境变量：

   • JAVA_HOME：指向 JDK 安装目录，例如 C:\Program Files\Java\jdk-17.0.1

   • Path 中添加 %JAVA_HOME%\bin

验证是否安装成功：

java -version
javac -version

---

二、下载 Kafka

访问 Apache Kafka 官网下载页面：

🔗 https://kafka.apache.org/downloads

选择最新的稳定版本，例如：

Latest release: kafka_2.13-3.9.0.tgz

Windows 用户选择 kafka_2.13-3.9.0.tgz 即可，Scala 版本不影响你在 Windows 上运行 Kafka。除非你自己用 Scala 编写客户端程序，否则任意版本都可以。社区推荐使用 2.13，因此建议你就选这个版本。

✅ 注意：Windows 上使用的是 Kafka 自带的 windows 脚本，不需要 Linux 工具支持。

---

三、解压 Kafka

虽然 Kafka 是为 Linux 设计的，但官方提供了部分 Windows 兼容脚本（位于 bin/windows/ 目录下），所以你可以放心地：

• 使用 zookeeper-server-start.bat
• 使用 kafka-server-start.bat
• 创建 Topic、发送和消费消息等操作都正常运行

只是要注意以下几点：

注意事项	说明
路径不要有空格或中文	推荐安装路径如 F:\kafka_2.13-3.9.0
日志文件位置	默认在 logs/ 目录下
性能略差于 Linux	本地开发没问题，生产建议用 Linux
不支持某些高级功能	如 log.dirs 中使用多个磁盘路径（Windows 下可能出错）

Kafka配置（kafka-logs的新建必要！！）

这个文件主要是存放分区的offerset，元文件，记录消费到哪里等等。

类型	存放内容
Topic 数据	每个 Topic 的分区数据都存在这里
Offset 信息	记录消费者组消费到的位置
元数据	分区状态、ISR（In-Sync Replicas）等
日志文件	controller.log、kafka-request.log 等

第一步：一定要需要建立一个空文件夹kafka-logs在bin、config同级！！

F:\kafka_2.13-3.9.0\
├── bin/
├── config/
├── logs/
└── kafka-logs/    ← 新建这个文件夹

第二步：编辑\kafka_2.13-3.9.0\config下的server.properties文件

log.dirs=/kafka-logs

除了 log.dirs，还有几个常用配置项也建议了解一下，其他改不改不影响基本使用：

配置项	默认值	说明
broker.id	0	Kafka 实例的唯一 ID，单机版保持默认即可
listeners	PLAINTEXT://:9092	Kafka 监听地址，默认本地访问
num.partitions	1	默认每个 topic 创建的分区数
log.retention.hours	168 (7天)	消息保留时间
log.segment.bytes	1GB	单个日志文件大小上限
message.max.bytes	1MB	最大消息体大小（生产环境可调大）

完整配置样例（适合 Windows 单节点开发，不必要，默认也可）

broker.id=0
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://localhost:9092
log.dirs=F:/kafka_2.13-3.9.0/kafka-logs
num.partitions=1
log.retention.hours=168
log.segment.bytes=1073741824
message.max.bytes=10485880
replica.lag.time.ms=10000
offsets.topic.replication.factor=1
transaction.state.log.replication.factor=1
transaction.state.log.min.isr=1

四、启动 Kafka与关闭Kafka（比较麻烦，需要打开多窗口执行）

✅ 1. 启动 ZooKeeper

Kafka 依赖 ZooKeeper 存储元数据信息。

打开 CMD，进入 Kafka 目录：

cd F:\kafka_2.13-3.9.0

执行以下命令启动 ZooKeeper：

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

✅ 成功标志：看到类似 INFO ... Starting zookeeper version... 的日志输出。

问题描述

有时zooKeeper报错:ZooKeeper audit is disabled.

[2023-02-18 12:17:27,368] INFO ZooKeeper audit is disabled. (org.apache.zookeeper.audit.ZKAuditProvider)

原因分析：

zookeeper设置参数问题

解决方案：

修改kafka安装目录下config文件中的zookeeper.properties文件

在文件中将false改为true，没有的话就添加下面语句

audit.enable=true

[2023-02-18 12:17:27,368] INFO ZooKeeper audit is enabled.(org.apache.zookeeper.audit.ZKAuditProvider)

---

✅ 2. 启动 Kafka

保持上一个窗口不要关闭，再打开一个新的 CMD 窗口，同样进入 Kafka 目录：

执行：

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

✅ 成功标志：看到 INFO [KafkaServer id=0] started (kafka.server.KafkaServer)

成功启动kafka图

---

✅ 步骤 3：关闭 Kafka

进入 Kafka 目录：

.\bin\windows\kafka-server-stop.bat

你会看到 Kafka 开始安全退出，等待几秒后自动结束。

---

✅ 步骤 4：关闭 ZooKeeper

继续在当前 CMD 窗口中执行：

.\bin\windows\zookeeper-server-stop.bat

ZooKeeper 也会优雅退出。

五、创建 Topic

新打开一个 CMD 窗口，创建一个测试用的 Topic：

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

参数说明：

• --topic：Topic 名称

• --partitions：分区数

• --replication-factor：副本数（本地开发设为 1 即可）

查看已创建的 Topic：

.\bin\windows\kafka-topics.bat --list --bootstrap-server localhost:9092

---

六、发送消息（Producer）

打开一个新 CMD 窗口，运行生产者控制台：

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

输入任意文字后按回车即可发送消息，比如：

>Hello Kafka!
>This is a test message.

---

七、消费消息（Consumer）

再新开一个 CMD 窗口，运行消费者控制台：

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

你会看到刚刚发送的消息被打印出来！

---

八、Windows 下如何正确启动和关闭 Kafka？

⚠️ 不要直接关闭 CMD 窗口也不要ctrl + c，都是强制关机！再次启动可能会有很多bug！

一定要使用官方的启动和关闭脚本！！！bug血泪！

因为：

• Ctrl + C 是发送 SIGINT 信号，Kafka 和 ZooKeeper 会尝试优雅关闭，但不一定能完成全部清理工作

• 如果用户误操作、窗口被意外关闭、或脚本中断，会导致：

  • .lock 文件残留

  • controller.log 重命名失败

  • ZooKeeper 节点未清除

  • Kafka Broker 状态未更新

---

九、推荐脚本（自动化启停）

为了方便你以后快速操作，我为你写好了两个批处理脚本：

放在同级目录下即可！

---

✅ 启动脚本：start-kafka.bat

@echo off
chcp 65001 > nul
TITLE Kafka 启动器 - kafka_2.13-3.9.0
​
SETLOCAL
​
set KAFKA_HOME=F:\kafka_2.13-3.9.0
​
if not exist "%KAFKA_HOME%" (
    echo ❌ 错误：KAFKA_HOME 路径不存在: %KAFKA_HOME%
    pause
    exit /b 1
)
​
cd /d %KAFKA_HOME%
​
:: 清理锁文件（防止上次异常退出导致冲突）
if exist "logs\*.lock" del /Q "logs\*.lock"
if exist "logs\*.pid" del /Q "logs\*.pid"
​
:: 启动 ZooKeeper
echo ▶️ 正在启动 ZooKeeper...
start "ZooKeeper" /D "%KAFKA_HOME%" call bin\windows\zookeeper-server-start.bat config\zookeeper.properties
​
:: 等待初始化完成
timeout /t 7 > NUL
​
:: 启动 Kafka
echo ▶️ 正在启动 Kafka Server...
call bin\windows\kafka-server-start.bat config\server.properties
​
echo ✅ Kafka 已成功启动！
pause

---

✅ 关闭脚本：stop-kafka.bat

@echo off
chcp 65001 > nul
TITLE Kafka 关闭器 - kafka_2.13-3.9.0
​
SETLOCAL
​
set KAFKA_HOME=F:\kafka_2.13-3.9.0
​
if not exist "%KAFKA_HOME%" (
    echo ❌ 错误：KAFKA_HOME 路径不存在: %KAFKA_HOME%
    pause
    exit /b 1
)
​
cd /d %KAFKA_HOME%
​
:: 停止 Kafka
echo ⏹️ 正在尝试优雅地停止 Kafka...
call "%KAFKA_HOME%\bin\windows\kafka-server-stop.bat"
​
:: 等待 Kafka 进程结束
call :wait_for_process_exit "kafka" 30
if errorlevel 1 (
    echo ⚠️ Kafka 进程未能在指定时间内退出，请检查日志或手动终止。
)
​
:: 停止 ZooKeeper
echo ⏹️ 正在尝试优雅地停止 ZooKeeper...
call "%KAFKA_HOME%\bin\windows\zookeeper-server-stop.bat"
​
:: 等待 ZooKeeper 进程结束
call :wait_for_process_exit "zookeeper" 30
if errorlevel 1 (
    echo ⚠️ ZooKeeper 进程未能在指定时间内退出，请检查日志或手动终止。
)
​
echo ✅ Kafka 和 ZooKeeper 已尝试优雅关闭。
pause
exit /b 0
​
​
:: ============ 函数区 ============
​
:: 等待指定关键字的 Java 进程退出
:wait_for_process_exit
setlocal
set keyword=%~1
set timeout=%~2
set count=0
​
echo 🔍 正在等待 [%keyword%] 进程退出，最多等待 %timeout% 秒...
​
:loop
tasklist | findstr /i java >nul && (
    tasklist | findstr /i %keyword% >nul && (
        if %count% lss %timeout% (
            timeout /t 1 >nul
            set /a count+=1
            goto loop
        ) else (
            endlocal
            exit /b 1
        )
    )
)
​
endlocal
exit /b 0

优雅地关闭Kafka

十、常见问题与解决方案

问题	可能原因	解决方案
Address already in use	上次未正常关闭 Kafka 或 ZooKeeper	使用 stop-kafka.bat 关闭服务，或重启电脑
Node does not exist	ZooKeeper 没有正确启动	确保 ZooKeeper 启动后再启动 Kafka
Class 'kafka.Kafka' could not be found	路径错误或 JDK 版本不对	检查 JAVA_HOME 是否设置正确
找不到或无法加载主类	Kafka 路径包含中文或空格	将 Kafka 安装到英文路径下

---