快捷導(dǎo)航

Windows安裝Kafka(kafka_2.12-3.9.1)配置Kafka的過程及遇到的問題解決方案

更新時(shí)間：2025年11月15日 10:03:08 作者：ljbguanli

文章詳細(xì)介紹了如何在Windows系統(tǒng)上安裝和配置Kafka,包括下載、解壓、配置日志目錄、修改配置文件、初始化存儲(chǔ)目錄、生成集群ID、配置KRaft模式、格式化日志目錄以及啟動(dòng)Kafka的步驟,本文給大家介紹的非常詳細(xì),感興趣的朋友一起看看吧

下載 Kafka

訪問 Apache Kafka 官網(wǎng)，選擇 Binary Downloads，下載 kafka_2.13-4.0.0.tgz（支持 Windows/Linux）。

依賴項(xiàng)

Kafka 4.0 基于 JDK 17 編譯，需提前安裝并配置 JAVA_HOME 環(huán)境變量。

安裝

將壓縮包解壓至短路徑目錄（如：E:\Kafka）

配置日志目錄

創(chuàng)建 Kafka 日志目錄（如 E:\Kafka\data\kafka\kafka-logs）。

修改配置文件

打開 config\server.properties，修改以下關(guān)鍵參數(shù)：

# 日志路徑（使用雙反斜杠）
log.dirs=E:\\Kafka\\data\\kafka\\kafka-logs

初始化存儲(chǔ)目錄

生成集群 ID：

// 進(jìn)入目錄：E:\Kafka\kafka\bin\windows下
// 輸入命令
kafka-storage.bat random-uuid

輸出示例如下：

上述日志中有個(gè)錯(cuò)誤提示可以忽略。記錄此ID：JnhYFIOcRXipOJdyvUlVcA
打開 config\server.properties，增加以下關(guān)鍵參數(shù)：

# 集群唯一標(biāo)識(shí)（之前生成的 UUID）
cluster.id=JnhYFIOcRXipOJdyvUlVcA
# 控制器選舉配置（單機(jī)模式示例）
controller.quorum.voters=1@localhost:9093

Kafka 4.0 默認(rèn)使用 KRaft 模式（Kafka Raft Metadata），取代了舊版的 ZooKeeper。在 KRaft 模式下，controller.quorum.voters 是必需配置，用于指定集群的控制器節(jié)點(diǎn)。

格式化日志目錄：

// 進(jìn)入目錄：E:\Kafka\kafka\bin\windows下
kafka-storage.bat format -t JnhYFIOcRXipOJdyvUlVcA -c ..\..\config\kraft\server.properties

表明 Kafka 存儲(chǔ)格式化成功

小插曲

這個(gè)錯(cuò)誤表明您正在嘗試使用 KRaft 模式格式化存儲(chǔ)，但配置文件是針對(duì) 舊版的 Zookeeper 模式的。Kafka 從 3.0 版本開始引入了 KRaft 模式（不再需要 Zookeeper）。

所以應(yīng)該使用kraft版本的配置文件

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

啟動(dòng) Kafka

在 bin\windows 目錄下執(zhí)行：

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

成功標(biāo)志：日志輸出如下內(nèi)容且無致命錯(cuò)誤：

驗(yàn)證 Kafka 是否正常工作

新開兩個(gè)cmd窗口

#創(chuàng)建一個(gè)名為 test-topic 的主題：
E:\Kafka\kafka\bin\windows>kafka-topics.bat --create --topic test-topic --partitions 1 --replication-factor 1 --bootstrap-server localhost:9092

#驗(yàn)證剛剛創(chuàng)建的主題是否正確添加：
E:\Kafka\kafka\bin\windows>kafka-topics.bat --list --bootstrap-server localhost:9092
test-topic

#發(fā)送和接收消息
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

#在另一個(gè)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

圓滿成功?。?！

到此這篇關(guān)于Windows安裝Kafka(kafka_2.12-3.9.1)，配置Kafka，以及遇到的困難解決方案的文章就介紹到這了,更多相關(guān)Windows安裝Kafka內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: