首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
您现在的位置: 程式碼之家 >> 編程語言 >  >> Java 程式設計 >> Java 綜合教學

Windows 上手把手安裝 Kafka 單節點環境(含 ZooKeeper 獨立部署)

     編輯:Java 綜合教學

前置條件

  • JDK 1.7+(必須,Kafka 依賴 Java 運行環境)
  • 下載地址:JDK 百度網盤(自行安裝配置 JAVA_HOME、PATH)

軟件包獲取

建議分離下載 ZooKeeper 與 Kafka,而非使用 Kafka 打包版 ZooKeeper(僅適合單節點測試)。

  • ZooKeeper 3.4.8:下載鏈接
  • Kafka 2.11-0.9.0.1:同鏈接包含

步驟 1:安裝獨立 ZooKeeper

1.1 解壓並配置 zoo.cfg

  • 解壓至 F:\zookeeper-3.4.8
  • 進入 conf 目錄,複製 zoo_sample.cfg 為 zoo.cfg
  • 編輯 zoo.cfg(建議用 Notepad++),修改 dataDir:
dataDir=F:/zookeeper-3.4.8/data
  • 手動創建 data 目錄,ZooKeeper 不會自動創建
  • 端口默認 2181 保持不變

1.2 配置環境變量

  • 新增系統變量:ZOOKEEPER_HOME=F:\zookeeper-3.4.8
  • 編輯 Path,追加 %ZOOKEEPER_HOME%\bin;(注意分號分隔,勿覆蓋原值)

1.3 啟動驗證

  • 在 bin 目錄按 Shift+右鍵 → 在此處打開命令視窗
  • 執行 zkServer.cmd
  • 日誌出現 binding to port 2181 即啟動成功

步驟 2:安裝 Kafka

2.1 解壓並配置 server.properties

  • 解壓至 F:\kafka_2.11-0.9.0.1
  • 編輯 config/server.properties,修改:
log.dirs=F:/kafka_2.11-0.9.0.1/kafka-logs
# 若 ZooKeeper 在其他機器,修改 zookeeper.connect=IP:2181
# 本機單節點保持默認 localhost:2181
  • 手動創建 kafka-logs 目錄

2.2 啟動 Kafka(務必先啟動 ZooKeeper)

  • 在 Kafka 根目錄 Shift+右鍵打開命令行
  • 執行:
.\bin\windows\kafka-server-start.bat .\config\server.properties
  • 日誌無錯誤、顯示 started 即成功

步驟 3:功能驗證(創建 Topic、生產消費測試)

3.1 創建 Topic

# 在 F:\kafka_2.11-0.9.0.1\bin\windows 目錄下
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

3.2 啟動生產者

kafka-console-producer.bat --broker-list localhost:9092 --topic test

3.3 啟動消費者(新開命令行)

kafka-console-consumer.bat --zookeeper localhost:2181 --topic test

3.4 測試

在生產者命令行輸入任意文字,消費者端即時接收顯示,驗證通過。

常見坑點提示

問題原因解決
Kafka 啟動報 java.lang.UnsupportedClassVersionErrorJDK 版本過低升級 JDK 1.7+,重新設置 JAVA_HOME
ZooKeeper 啟動閃退dataDir 未創建或路徑錯誤檢查 zoo.cfg 中 dataDir 路徑並手動建立目錄
生產者/消費者連不上防火牆攔截 9092/2181 端口關閉防火牆或放行端口
Topic 創建報 Replication factor invalid單節點 replication-factor 必須為 1單機測試固定用 1

後續學習方向

  • Java/Scala 客戶端 API 開發(Producer/Consumer/Streams)
  • Kafka 集群部署、副本機制、ISR、控制器選舉
  • 與 Spring Boot 整合、Spring Cloud Stream 綁定
  • 監控運維:Kafka Manager、Confluent Control Center、Prometheus Exporter
  1. 上一篇文章:
  2. 下一篇文章:
Copyright © 程式碼之家 All Rights Reserved