java

关注公众号 jb51net

关闭
首页 > 软件编程 > java > Windows安装Kafka

Windows安装Kafka(kafka_2.12-3.9.1)配置Kafka的过程及遇到的问题解决方案

作者:ljbguanli

文章详细介绍了如何在Windows系统上安装和配置Kafka,包括下载、解压、配置日志目录、修改配置文件、初始化存储目录、生成集群ID、配置KRaft模式、格式化日志目录以及启动Kafka的步骤,本文给大家介绍的非常详细,感兴趣的朋友一起看看吧

下载 Kafka

访问 Apache Kafka 官网,选择 Binary Downloads,下载 kafka_2.13-4.0.0.tgz(支持 Windows/Linux)。

依赖项

Kafka 4.0 基于 JDK 17 编译,需提前安装并配置 JAVA_HOME 环境变量。

安装

将压缩包解压至短路径目录(如:E:\Kafka)

配置日志目录

创建 Kafka 日志目录(如 E:\Kafka\data\kafka\kafka-logs)。

修改配置文件

打开 config\server.properties,修改以下关键参数:

# 日志路径(使用双反斜杠)
log.dirs=E:\\Kafka\\data\\kafka\\kafka-logs

初始化存储目录

生成集群 ID:

// 进入目录:E:\Kafka\kafka\bin\windows下
// 输入命令
kafka-storage.bat random-uuid

输出示例如下:

上述日志中有个错误提示可以忽略。记录此ID:JnhYFIOcRXipOJdyvUlVcA
打开 config\server.properties,增加以下关键参数:

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

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

格式化日志目录:

// 进入目录:E:\Kafka\kafka\bin\windows下
kafka-storage.bat format -t JnhYFIOcRXipOJdyvUlVcA -c ..\..\config\kraft\server.properties

表明 Kafka 存储格式化成功

小插曲

这个错误表明您正在尝试使用 KRaft 模式格式化存储,但配置文件是针对 旧版的 Zookeeper 模式的。Kafka 从 3.0 版本开始引入了 KRaft 模式(不再需要 Zookeeper)。

所以应该使用kraft版本的配置文件

# 使用 kraft 版本的配置文件
kafka-storage.bat format -t JnhYFIOcRXipOJdyvUlVcA -c ..\..\config\kraft\server.properties

启动 Kafka

bin\windows 目录下执行:

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

成功标志:日志输出如下内容且无致命错误:

验证 Kafka 是否正常工作

新开两个cmd窗口

#创建一个名为 test-topic 的主题:
E:\Kafka\kafka\bin\windows>kafka-topics.bat --create --topic test-topic --partitions 1 --replication-factor 1 --bootstrap-server localhost:9092

#验证刚刚创建的主题是否正确添加:
E:\Kafka\kafka\bin\windows>kafka-topics.bat --list --bootstrap-server localhost:9092
test-topic

#发送和接收消息
E:\Kafka\kafka\bin\windows>kafka-console-producer.bat --bootstrap-server localhost:9092 --topic test-topic
>Hello Kafka
>this is a test message
>i am codesandwich

#在另一个cmd窗口
E:\Kafka\kafka\bin\windows>kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test-topic --from-beginning
Hello Kafka
this is a test message
i am codesandwich

圆满成功!!!

到此这篇关于Windows安装Kafka(kafka_2.12-3.9.1),配置Kafka,以及遇到的困难解决方案的文章就介绍到这了,更多相关Windows安装Kafka内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

您可能感兴趣的文章:
阅读全文