kafka

官网：https://kafka.apache.org/downloads

官方下载链接：https://dlcdn.apache.org/kafka/4.1.0/kafka_2.13-4.1.0.tgz

阿里云镜像下载：https://mirrors.aliyun.com/apache/kafka/

注意,

从 Kafka 2.8.0 版本开始，引入了 KRaft (Kafka Raft Metadata) 模式，这意味着 在较新版本的 Kafka 中，已经不再强制需要先安装 ZooKeeper (ZK)。

Kafka 4.1.0 需要 Java 17 或更高版本

windows环境安装

再次注意，我的是最新版本 v4.1.0 的安装教程！！！

解压

略...

生成uuid

D:\devtool\kafka_2.13-4.1.0\bin\windows>kafka-storage.bat random-uuid
2025-10-29T15:11:36.577382700Z main ERROR Reconfiguration failed: No configuration found for '24d46ca6' at 'null' in 'null'
hQIrHrZNQtyLnN0mHyc1zQ

上述日志中有个错误提示可以忽略。记录此ID：hQIrHrZNQtyLnN0mHyc1zQ

修改配置

打开 config\server.properties，增加以下关键参数：

# 日志路径（使用双反斜杠）
log.dirs=D:\\devtool\\kafka_2.13-4.1.0\\kafka-logs

# 集群唯一标识（之前生成的 UUID）
cluster.id=4LBwTZK_QhCTbsmqDPw4lw
 
# 控制器选举配置（单机模式示例）
controller.quorum.voters=1@localhost:9093

Kafka 4.0 默认使用 KRaft 模式（Kafka Raft Metadata），取代了旧版的 ZooKeeper。 在 KRaft 模式下，controller.quorum.voters 是必需配置，用于指定集群的控制器节点。

格式化日志目录

kafka-storage.bat format -t hQIrHrZNQtyLnN0mHyc1zQ -c ..\..\config\server.properties

验证：检查 D:\\devtool\\kafka_2.13-4.1.0\\kafka-logs 目录下是否生成 meta.properties 和 bootstrap.checkpoint 文件。

启动 Kafka

在 bin\windows 目录下执行：

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

启动成功最后日志打印

[2025-10-29 23:08:48,292] INFO [BrokerServer id=1] Transition from STARTING to STARTED (kafka.server.BrokerServer)
[2025-10-29 23:08:48,296] INFO Kafka version: 4.1.0 (org.apache.kafka.common.utils.AppInfoParser)
[2025-10-29 23:08:48,303] INFO Kafka commitId: 13f70256db3c994c (org.apache.kafka.common.utils.AppInfoParser)
[2025-10-29 23:08:48,304] INFO Kafka startTimeMs: 1761750528294 (org.apache.kafka.common.utils.AppInfoParser)
[2025-10-29 23:08:48,308] INFO [KafkaRaftServer nodeId=1] Kafka Server started (kafka.server.KafkaRaftServer)