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

 更新时间:2025年11月15日 10:03:08   作者: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内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • JAVA 实现磁盘文件加解密操作的示例代码

    JAVA 实现磁盘文件加解密操作的示例代码

    这篇文章主要介绍了JAVA 实现磁盘文件加解密操作的示例代码,帮助大家利用Java实现文件的加解密,感兴趣的朋友可以了解下
    2020-09-09
  • 详解Spring Boot 添加JSP支持

    详解Spring Boot 添加JSP支持

    本篇文章主要介绍了详解Spring Boot 添加JSP支持,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-05-05
  • mybatis的association传递参数问题示例

    mybatis的association传递参数问题示例

    这篇文章主要介绍了mybatis的association传递参数问题,本文通过示例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2022-12-12
  • Java 数据结构与算法系列精讲之单向链表

    Java 数据结构与算法系列精讲之单向链表

    单向链表特点是链表的链接方向是单向的,访问要通过顺序读取从头部开始。链表是使用指针构造的列表,是由一个个结点组装起来的,又称为结点列表。其中每个结点都有指针成员变量指向列表中的下一个结点,head指针指向第一个结点称为表头,而终止于最后一个指向nuLL的指针
    2022-02-02
  • 使用Apache POI在Java中实现Excel单元格的合并

    使用Apache POI在Java中实现Excel单元格的合并

    在日常工作中,Excel是一个不可或缺的工具,尤其是在处理大量数据时,本文将介绍如何使用 Apache POI 库在 Java 中实现 Excel 单元格的合并,需要的可以了解下
    2025-03-03
  • JPA延迟加载no Session报错解决分析

    JPA延迟加载no Session报错解决分析

    这篇文章主要为大家介绍了JPA延迟加载no Session报错解决分析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-09-09
  • 从零开始让你的Spring Boot项目跑在Linux服务器

    从零开始让你的Spring Boot项目跑在Linux服务器

    这篇文章主要给大家介绍了如何从零开始让你的Spring Boot项目跑在Linux服务器的相关资料,由于springboot是内嵌了tomcat,所以可以直接将项目打包上传至服务器上,需要的朋友可以参考下
    2021-11-11
  • Java多线程优化方法及使用方式

    Java多线程优化方法及使用方式

    这篇文章主要介绍了Java多线程优化方法及使用方式,非常不错,具有参考借鉴价值,需要的朋友可以参考下
    2018-02-02
  • java  HttpServletRequest和HttpServletResponse详解

    java HttpServletRequest和HttpServletResponse详解

    这篇文章主要介绍了java HttpServletRequest和HttpServletResponse详解的相关资料,需要的朋友可以参考下
    2016-12-12
  • SpringCloud降级规则使用介绍

    SpringCloud降级规则使用介绍

    这篇文章主要介绍了SpringCloud降级规则,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2022-08-08

最新评论