Kafka Console UI把多集群運維從命令行搬進瀏覽器【免費下載鏈接】kafka-console-ui一款快捷易用的輕量級kafka可視化管理平臺項目地址: https://gitcode.com/gh_mirrors/ka/kafka-console-ui如果你還在用 kafka-console-consumer 一條條翻消費組、用腳本撈消息Kafka Console UI 可以把這些事搬進瀏覽器集群切換、Topic 管理、消費組延遲查看、消息查詢都在一個中文 Web 界面里完成解壓啟動后訪問 7766 端口就能開始操作。30 秒判斷值不值得用和命令行腳本、自己拼的監(jiān)控頁相比它的取舍比較明確? 單包解壓即用不額外依賴 ZK 等組件 多集群運維集群信息獨立管理隨時切換 消費組 lag、分區(qū)副本狀態(tài)直接在頁面上看 登錄認證加按鈕級權(quán)限能給開發(fā)發(fā)只讀賬號跑起來Windows 啟動下載 kafka-console-ui.zip 并解壓進入bin目錄JDK 8 雙擊start_jdk8.batJDK 11 及以上雙擊start.batPowerShell 用戶可改用start.ps1瀏覽器訪問http://127.0.0.1:7766停止服務(wù)直接關(guān)閉命令行窗口Linux / macOS 啟動unzip kafka-console-ui.zip cd kafka-console-ui sh bin/start.sh # 停止sh bin/shutdown.sh默認端口 7766啟動完成后訪問http://127.0.0.1:7766。內(nèi)置 Kafka 3.5.0 客戶端與主流 Kafka 版本兼容。問題首次打開頁面提示 No Cluster Info / 沒有集群信息請先切換集群。這是正?，F(xiàn)象此時還沒有登記任何集群。解決點導(dǎo)航欄「運維」→「集群管理」→「集群切換」彈框中點「新增集群」填名稱和 Kafka 地址bootstrap servers提交后點右側(cè)「切換」頁面右上角顯示當(dāng)前集群名即成功提示不確定當(dāng)前在哪個集群時刷新頁面右上角會顯示當(dāng)前集群名。核心操作走一遍添加與切換 Kafka 集群給控制臺登記集群、并在多個集群間跳轉(zhuǎn)是其他所有操作的前提。點「運維」→「集群切換」打開集群列表彈框點「新增集群」填集群名稱和 Kafka 地址提交點該集群右側(cè)「切換」整個界面即指向新集群如果集群開了 SASL 認證還要在新增集群的屬性里填安全協(xié)議、SASL 機制和管理員賬號切到該集群后導(dǎo)航欄會自動出現(xiàn)「Acl」菜單。注意可視化認證用戶管理目前只支持 SCRAM 機制屬性里沒填 ACL 信息時「Acl」菜單不會出現(xiàn)。創(chuàng)建與查看 Topic新建 Topic 不用拼 create-topics.sh 參數(shù)表單里填完就建。進入「Topic」頁面點「新增 Topic」填 Topic 名稱、分區(qū)數(shù)、副本因子提交列表中點「詳情」查看每個分區(qū)的 Leader、ISR 和副本分布提示分區(qū)數(shù)只能增不能減創(chuàng)建前按業(yè)務(wù)量預(yù)估。Kafka 消費組延遲查看判斷消費卡沒卡看每個分區(qū)的 lag 就夠了不用跑 describe-consumer-groups。進入「消費組」頁面列表直接展示各組狀態(tài)和分區(qū) lag點「詳情」查看組內(nèi)成員和分區(qū)分配需要重置位點時在詳情里按時間重置注意重置位點會影響正在消費的組生產(chǎn)環(huán)境先確認業(yè)務(wù)能接受。Kafka 消息按時間查詢排查某條消息去哪了按時間范圍撈消息最直接。進入「消息」頁面選 Topic 并設(shè)置時間范圍提交后查看命中列表點「詳情」看 Key、Value 和 Offset同一頁面還支持按 Offset 精確查詢提示時間范圍別拉太寬大 Topic 上全量掃描會很慢。配置與安全登錄認證默認關(guān)閉生產(chǎn)環(huán)境建議開啟。修改config/application.ymlauth: enable: true # 生產(chǎn)環(huán)境必須開啟 expire-hours: 24 # 登錄 token 過期時間小時默認賬號生產(chǎn)環(huán)境必須修改密碼或重建賬號角色權(quán)限范圍默認賬號超級管理員用戶、角色、權(quán)限管理super-admin / 123456管理員日常運維不能增刪用戶admin / 123456不開認證時頁面不顯示「用戶」菜單屬正?，F(xiàn)象。怎么改它需要定制時Kafka Console UI 的代碼分布比較清晰src/main/javaSpring Boot 后端controller / service 分層src/main/scalaKafka 客戶端操作封裝ui/srcVue 前端頁面打包需要 Maven 3.6 和 JDK 8git clone https://gitcode.com/gh_mirrors/ka/kafka-console-ui cd kafka-console-ui sh package.sh產(chǎn)物在target/kafka-console-ui.zip。本地開發(fā)需要 Scala 2.13 環(huán)境見 開發(fā)配置。回到開頭那個場景消費組 lag、消息去向、新集群接入都不再需要打開終端。下一步建議按角色分發(fā)控制臺賬號開發(fā)只讀、運維可寫并把它和外部監(jiān)控告警一起納入值班流程。【免費下載鏈接】kafka-console-ui一款快捷易用的輕量級kafka可視化管理平臺項目地址: https://gitcode.com/gh_mirrors/ka/kafka-console-ui創(chuàng)作聲明：本文部分內(nèi)容由AI輔助生成（AIGC），僅供參考