Kafka 可视化管理平台完全实操:Kafka Console UI 从启动到多集群运维
【免费下载链接】kafka-console-ui一款快捷易用的轻量级kafka可视化管理平台项目地址: https://gitcode.com/gh_mirrors/ka/kafka-console-ui
如果你每天都在和命令行打交道——查分区、翻 offset、对副本、查消费 lag——那么你需要一套真正的 Kafka 可视化管理平台。Kafka Console UI 就是这样一款轻量级的 Kafka 可视化管理工具:Web 页面覆盖 Topic 管理、消费组监控、消息查询、ACL 权限、客户端限流这些高频运维动作,下载压缩包即可启动,几乎没有环境负担。
这篇文章不讲概念,只带你走一遍真实使用路径:装起来 → 接上集群 → 每天用它干什么 → 需要安全加固和二次开发时怎么改。
两种落地方式,先选对路线
按"要不要动代码"选路线,比纠结技术细节更重要:
| 路线 | 适合人群 | 做法 | 产出 |
|---|---|---|---|
| 下载部署 | 只想马上用 | 解压发行包,进bin目录执行启动脚本 | 立即可用的 Web 控制台 |
| 源码构建 | 想二次开发、改功能 | clone 仓库后执行打包脚本 | 可定制版本 |
源码路线的仓库地址为 https://gitcode.com/gh_mirrors/ka/kafka-console-ui ,克隆后进入项目根目录执行 package.sh 即可完成编译打包(底层是 Maven,脚本里是mvn clean scala:compile compile package)。本地开发环境怎么搭,直接看 开发配置文档,里面写得很细。
项目基于 Kafka 3.5.0 开发(见 pom.xml 中的
kafka.version),主流版本集群基本都能对接,实际以你的集群版本为准。
三步启动 Kafka 管理界面
方式一:Windows
- 下载
kafka-console-ui.zip并解压; - 进入
bin目录,按 JDK 版本选择脚本:JDK 1.8 双击start_jdk8.bat,更高版本双击start.bat(PowerShell 用户可改用start.ps1); - 浏览器打开
http://127.0.0.1:7766—— 端口 7766 是默认值,配置在 application.yml 里。
方式二:Linux / Mac
unzip kafka-console-ui.zip cd kafka-console-ui sh bin/start.sh # 停止时执行 sh bin/shutdown.sh启动成功后页面是干净的,但先别急着找功能——它会提示没有可用集群。这不是故障,是正常的首次状态。
第一次登录:把集群接进来
首次使用只需做一件事:把目标 Kafka 集群登记进来。
- 点右上角运维菜单;
- 进入集群管理 → 集群切换,点击新增集群;
- 填写连接地址、超时、ACL 相关配置,保存。
配置完成后再回首页,整个平台的"集群视角"就建立了。多集群管理在这里体现得很直接:集群列表可以增删,右上角始终显示当前正在操作的集群名,你在任何页面做的 Topic 管理、消费组监控操作,都落在当前选中的集群上。
建议:切换集群后刷新一下页面再操作,并养成"瞄一眼右上角集群名"的习惯,避免在错误的环境上执行写操作。
日常运维:四件最常用的事
下面四个场景覆盖了大部分日常需求,界面见下图。
1)Topic 管理—— 看全量 Topic、按分区查看副本与 offset、创建新 Topic(指定分区数和副本)、删除废弃 Topic,生产消费状态一眼可见。
2)消费组监控—— 消费组状态、各分区 lag 分布、成员列表都在这里;发现 lag 堆积后,可以直接在页面上重置消费 offset(支持按时间点重置)。
3)消息查询—— 支持按时间范围和按 offset 两种检索方式,命中后可以查看消息详情,还能把消息转发到别处或执行删除。这是排查"某条消息去哪了"类问题时最好用的入口。
4)Broker 配置—— 在线查看、修改 Broker 参数,支持动态参数调整,不用登录机器翻server.properties。
进阶两件事:客户端限流与安全认证
客户端限流(Quota):除了按用户、按 client.id,还支持按 IP 维度配置生产/消费速率上限,适合多租户混部时防止个别客户端打满带宽。配置好之后有独立的限流列表页可以查看和调整,属于"不重启集群、在线生效"的那类操作。
登录认证:默认是免登录直进。需要收口权限时,在 application.yml 中把auth.enable置为true,expire-hours控制 token 有效期(示例值为 24 小时),重启即可生效。
系统内置两个默认账号:
| 账号 | 密码 | 定位 |
|---|---|---|
super-admin | 123456 | 超级管理员,可管理用户与角色 |
admin | 123456 | 普通管理员 |
生产环境第一件事:登录
super-admin改掉默认密码。权限模型是"角色 → 按钮级"的细粒度控制,登录用户也可以自助修改自己的密码。
看懂源码结构,为定制做准备
如果你想加功能或改交互,三个目录就够定位了:
- 后端 Java 代码:
src/main/java(Controller / Service / DAO 分层清晰,鉴权在aspect和filter包里); - 前端 Vue 页面:
ui/src/views(按 topic、group、message、quota、user 等模块分目录,对应你看到的功能页); - 与 Kafka 内核交互的 Scala 模块:
src/main/scala(如TopicConsole.scala、ConsumerConsole.scala、ClientQuotaConsole.scala)。
改完前端重新构建ui,改完整体执行sh package.sh即可产出部署包。
最后总结一下使用姿态:把 Kafka Console UI 当作浏览器里的 Kafka 运维面板——读操作随便点,写操作(建 Topic、删消息、重置 offset、改限流)前先看一眼右上角的集群名。做到这一点,它就能安全地接管你日常 90% 的 Kafka 管理动作。
【免费下载链接】kafka-console-ui一款快捷易用的轻量级kafka可视化管理平台项目地址: https://gitcode.com/gh_mirrors/ka/kafka-console-ui
创作声明:本文部分内容由AI辅助生成(AIGC),仅供参考