脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → Windows安装Kafka

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 大小写最快转换方式实例代码的相关资料,需要的朋友可以参考下
    2017-07-07
  • Java 实现拦截器Interceptor的拦截功能方式

    Java 实现拦截器Interceptor的拦截功能方式

    这篇文章主要介绍了Java 实现拦截器Interceptor的拦截功能方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2021-10-10
  • Java单例模式的深入了解

    Java单例模式的深入了解

    这篇文章主要为大家介绍了Java单例模式，具有一定的参考价值，感兴趣的小伙伴们可以参考一下，希望能够给你带来帮助
    2022-01-01
  • spring中bean id相同引发故障的分析与解决

    spring中bean id相同引发故障的分析与解决

    最近在工作中遇到了关于bean id相同引发故障的问题，通过查找相关资料终于解决了，下面这篇文章主要给大家介绍了因为spring中bean id相同引发故障的分析与解决方法，需要的朋友可以参考借鉴，下面来一起看看吧。
    2017-09-09
  • java LeetCode题解不同路径

    java LeetCode题解不同路径

    这篇文章主要为大家介绍了java LeetCode题解不同路径示例，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
    2023-06-06
  • Spring MVC映射HTTP请求到Controller的处理方法

    Spring MVC映射HTTP请求到Controller的处理方法

    我们来详细分析一下如何在 Spring MVC 中将 HTTP 请求映射到 Controller 的处理方法（Handler Methods）上,以及 @RequestMapping 注解的使用方法,需要的朋友可以参考下
    2025-05-05
  • SpringSecurity安全管理开发过程

    SpringSecurity安全管理开发过程

    Spring 是一个非常流行和成功的 Java 应用开发框架,Spring Security 基于 Spring 框架,提供了一套 Web 应用安全性的完整解决方案,这篇文章主要介绍了SpringSecurity安全管理,需要的朋友可以参考下
    2024-07-07
  • SpringMVC使用第三方组件实现文件上传

    SpringMVC使用第三方组件实现文件上传

    这篇文章主要介绍了SpringMVC使用第三方组件实现文件上传,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-08-08
  • 如何用java给一个文件夹打成压缩包(附代码)

    如何用java给一个文件夹打成压缩包(附代码)

    项目中需要将文件夹打包成压缩包下载,所以下面这篇文章主要给大家介绍了关于如何用java给一个文件夹打成压缩包的相关资料,文中给出了详细的代码示例,需要的朋友可以参考下
    2023-10-10
  • Java基础之TreeMap详解

    Java基础之TreeMap详解

    这篇文章主要介绍了Java基础之TreeMap详解,文中有非常详细的代码示例,对正在学习java基础的小伙伴们有非常好的帮助,需要的朋友可以参考下
    2021-04-04

最新评论