Windows?系統(tǒng)上安裝?Kafka的詳細(xì)步驟
Windows 系統(tǒng)上安裝 Kafka 。以下是詳細(xì)的步驟指南。
前置條件
- 1.Java 環(huán)境:Kafka 需要 Java 8 或更高版本。這是必須的。
- 打開命令提示符(CMD)或 PowerShell,輸入
java -version進(jìn)行檢查。 - 如果未安裝,請(qǐng)前往 Oracle Java或 OpenJDK官網(wǎng)下載并安裝。
- 2.下載 Kafka:訪問 Apache Kafka 官網(wǎng)下載頁(yè)面。
- 下載二進(jìn)制版本,例如:
kafka_2.13-3.6.1.tgz。注意,這是.tgz壓縮包。 - •重要提示:由于 Windows 不原生支持
.tgz格式,你還需要一個(gè)解壓工具,如 7-Zip或 PeaZip。
安裝步驟(使用 ZooKeeper 的經(jīng)典方式)
這是最常用和穩(wěn)定的方式。
步驟 1:下載并解壓 Kafka
- 1.將下載好的
kafka_2.13-3.6.1.tgz文件移動(dòng)到你想安裝的目錄,例如C:\` 根目錄或C:\Tools`。 - 2.右鍵單擊該文件,使用 7-Zip 等工具將其解壓。通常需要解壓兩次:
- •第一次解壓得到
.tar文件。 - •第二次解壓
.tar文件得到最終的文件夾kafka_2.13-3.6.1。 - 3.為了便于管理,可以將文件夾重命名為
kafka。最終路徑可能像C:\kafka。
步驟 2:配置 Kafka(可選,但常需修改)
用記事本或任何文本編輯器打開 C:\kafka\config\server.properties文件。
找到并修改以下行,以解決在 Windows 上可能出現(xiàn)的地址綁定錯(cuò)誤:
# 將 # listeners=PLAINTEXT://:9092 # 修改為(注意是 0.0.0.0 而不是 localhost) listeners=PLAINTEXT://0.0.0.0:9092 # 同樣,將 advertised.listeners 也修改為你的主機(jī)名或IP(如果是本地學(xué)習(xí),用 localhost 即可) advertised.listeners=PLAINTEXT://localhost:9092
保存并關(guān)閉文件。
步驟 3:?jiǎn)?dòng)服務(wù)
Kafka 的運(yùn)行依賴于 ZooKeeper。我們需要先啟動(dòng) ZooKeeper,再啟動(dòng) Kafka。
重要:? 你需要打開兩個(gè)獨(dú)立的命令提示符(CMD)或 PowerShell 窗口,并且都以管理員身份運(yùn)行(避免可能出現(xiàn)的權(quán)限問題)。兩個(gè)窗口都需要先進(jìn)入 Kafka 的安裝目錄。
# 切換到 Kafka 目錄(請(qǐng)根據(jù)你的實(shí)際路徑修改) cd C:\kafka
窗口 1:?jiǎn)?dòng) ZooKeeper
在第一個(gè)窗口中,執(zhí)行以下命令來(lái)啟動(dòng) ZooKeeper 服務(wù):
.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties
這個(gè)窗口會(huì)開始打印日志,ZooKeeper 將在默認(rèn)端口 2181上啟動(dòng)。讓這個(gè)窗口保持打開狀態(tài)。
窗口 2:?jiǎn)?dòng) Kafka Broker
在第二個(gè)窗口中,執(zhí)行以下命令來(lái)啟動(dòng) Kafka 服務(wù):
.\bin\windows\kafka-server-start.bat .\config\server.properties
這個(gè)窗口也會(huì)開始打印日志,Kafka 將在默認(rèn)端口 9092上啟動(dòng)。同樣,讓這個(gè)窗口保持打開狀態(tài)。
現(xiàn)在,ZooKeeper 和 Kafka 都已經(jīng)在你的本地機(jī)器上運(yùn)行起來(lái)了。
步驟 4:測(cè)試安裝(創(chuàng)建主題、發(fā)送和接收消息)
現(xiàn)在我們需要打開第三個(gè)命令提示符或 PowerShell 窗口(同樣建議管理員身份)來(lái)測(cè)試 Kafka 是否正常工作。
1.
創(chuàng)建一個(gè)測(cè)試主題(Topic)
在第三個(gè)窗口中,進(jìn)入 Kafka 目錄后,運(yùn)行以下命令創(chuàng)建一個(gè)名為 test-topic的主題:
cd C:\kafka .\bin\windows\kafka-topics.bat --create --topic test-topic --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1
如果成功,你會(huì)看到提示 Created topic test-topic。
2.
啟動(dòng)一個(gè)生產(chǎn)者(Producer)來(lái)發(fā)送消息
繼續(xù)在第三個(gè)窗口中,運(yùn)行以下命令啟動(dòng)控制臺(tái)生產(chǎn)者:
.\bin\windows\kafka-console-producer.bat --topic test-topic --bootstrap-server localhost:9092
命令執(zhí)行后,光標(biāo)會(huì)等待你輸入。鍵入幾條消息,每輸完一條按回車,例如:
> Hello, Kafka! > This is a test message.
3.
啟動(dòng)一個(gè)消費(fèi)者(Consumer)來(lái)接收消息
現(xiàn)在,打開第四個(gè)命令窗口,進(jìn)入 Kafka 目錄,運(yùn)行以下命令啟動(dòng)控制臺(tái)消費(fèi)者:
cd C:\kafka .\bin\windows\kafka-console-consumer.bat --topic test-topic --from-beginning --bootstrap-server localhost:9092
啟動(dòng)后,你應(yīng)該能立刻看到之前在生產(chǎn)者窗口輸入的所有消息顯示在這個(gè)消費(fèi)者窗口中。
恭喜!你的 Windows Kafka 安裝已經(jīng)成功并可以正常工作了!
作為 Windows 服務(wù)安裝(推薦用于長(zhǎng)期使用)
手動(dòng)打開多個(gè)窗口非常麻煩。我們可以使用第三方工具(如 NSSM)將 ZooKeeper 和 Kafka 安裝為 Windows 服務(wù),從而實(shí)現(xiàn)開機(jī)自啟和后臺(tái)運(yùn)行。
1.
下載 NSSM:訪問 NSSM 官網(wǎng)下載最新版本,解壓后根據(jù)你的系統(tǒng)(32/64位)將 nssm.exe文件復(fù)制到 C:\kafka\bin\windows目錄下,或者任何在系統(tǒng) PATH 環(huán)境變量中的目錄。
2.
安裝 ZooKeeper 服務(wù)
以管理員身份打開命令提示符:
nssm install zookeeper
•在彈出窗口的 "Path" 欄,點(diǎn)擊 "Browse",找到 C:\kafka\bin\windows\zookeeper-server-start.bat。
•在 "Arguments" 欄,輸入 C:\kafka\config\zookeeper.properties。
•在 "Service name" 欄,確保是 zookeeper。
•點(diǎn)擊 "Install service"。
3.
安裝 Kafka 服務(wù)
同樣在管理員命令提示符下:
nssm install kafka
•"Path" 欄,瀏覽選擇 C:\kafka\bin\windows\kafka-server-start.bat。
•"Arguments" 欄,輸入 C:\kafka\config\server.properties。
•"Service name" 欄,確保是 kafka。
•點(diǎn)擊 "Install service"。
4.
啟動(dòng)服務(wù)
打開"服務(wù)"應(yīng)用程序(按 Win + R,輸入 services.msc),找到 "zookeeper" 和 "kafka" 服務(wù),右鍵單擊并選擇"啟動(dòng)"。你也可以通過(guò)命令行啟動(dòng):
net start zookeeper net start kafka
現(xiàn)在,ZooKeeper 和 Kafka 就會(huì)在后臺(tái)作為服務(wù)運(yùn)行,無(wú)需再手動(dòng)打開命令窗口。
總結(jié)
•簡(jiǎn)單測(cè)試:按照步驟 1-4 手動(dòng)啟動(dòng)兩個(gè)窗口即可。
•長(zhǎng)期開發(fā)/學(xué)習(xí):強(qiáng)烈推薦使用 NSSM 將其安裝為 Windows 服務(wù),一勞永逸。
到此這篇關(guān)于Windows 系統(tǒng)上安裝 Kafka的詳細(xì)步驟的文章就介紹到這了,更多相關(guān)Windows 安裝 Kafka內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
IntelliJ IDEA 中g(shù)it的使用圖文教程
本文通過(guò)圖文并茂的形式給大家介紹了IntelliJ IDEA 中g(shù)it的使用,非常不錯(cuò),具有參考借鑒價(jià)值,需要的朋友參考下吧2018-02-02
解決IntelliJ IDEA創(chuàng)建spring boot無(wú)法連接http://start.spring.io/問題
這篇文章主要介紹了解決IntelliJ IDEA創(chuàng)建spring boot無(wú)法連接http://start.spring.io/問題,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2020-08-08
java使用google身份驗(yàn)證器實(shí)現(xiàn)動(dòng)態(tài)口令驗(yàn)證的示例
本篇文章主要介紹了java使用google身份驗(yàn)證器實(shí)現(xiàn)動(dòng)態(tài)口令驗(yàn)證的示例,具有一定的參考價(jià)值,有興趣的可以了解一下2017-08-08
SpringBoot項(xiàng)目嵌入RocketMQ的實(shí)現(xiàn)示例
本文主要介紹了SpringBoot項(xiàng)目嵌入RocketMQ的實(shí)現(xiàn)示例,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2024-05-05
Maven通過(guò)filtering標(biāo)簽讀取變量配置的三種方法
在日常開發(fā)中,我們大多都會(huì)有開發(fā)環(huán)境、測(cè)試環(huán)境、生產(chǎn)環(huán)境等,不同環(huán)境的參數(shù)肯定不一樣,本文主要介紹了Maven通過(guò)filtering標(biāo)簽讀取變量配置的三種方法,感興趣的可以了解一下2024-03-03
Mybatis如何使用正則模糊匹配多個(gè)數(shù)據(jù)
這篇文章主要介紹了Mybatis如何使用正則模糊匹配多個(gè)數(shù)據(jù),具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2022-01-01

