当前位置：首页 > news >正文

Kafka Console UI：5分钟怎么把轻量级 Kafka 可视化管理平台跑起来

news 2026/8/27 1:38:33

Kafka Console UI：5分钟怎么把轻量级 Kafka 可视化管理平台跑起来

【免费下载链接】kafka-console-ui一款快捷易用的轻量级kafka可视化管理平台项目地址: https://gitcode.com/gh_mirrors/ka/kafka-console-ui

Kafka 集群排查还得敲命令行脚本的时候，Kafka Console UI 用浏览器替代了大部分kafka-topics.sh操作。它是一款轻量级 Kafka 可视化管理平台，多集群、Topic、消费组、消息查询都能在页面上完成，下载即用。

5分钟跑起来：Windows 和 Linux 的启动差异

拿到 kafka-console-ui.zip 安装包后，两条路：

Windows：解压后进入bin目录，JDK 高于 1.8 双击start.bat，JDK 1.8 双击start_jdk8.bat（PowerShell 用户跑start.ps1）。停止服务直接关掉命令行窗口就行。

Linux / Mac：

unzip kafka-console-ui.zip cd kafka-console-ui sh bin/start.sh # 停止：sh bin/shutdown.sh

两种方式都是启动完成后访问http://127.0.0.1:7766。

⚠️ 最高频的坑：首次打开页面右上角提示 "No Cluster Info" 或"没有集群信息，请先切换集群"。这不是故障，是还没配集群——点顶部导航的「运维」→「集群管理」→「集群切换」，在弹框里点「新增集群」，填 Kafka 集群地址（如127.0.0.1:9092）和任意名称，提交后点「切换」。后续再挂别的集群就重复这个流程，页面右上角始终显示当前所在集群，不确定就刷新一下页面。

跟着场景走：三个高频任务

新建 Topic 并设好分区副本

Topic 菜单下点「创建 Topic」，填名称、分区数、副本因子、自定义配置项（如retention.ms），提交即建。建完不用翻命令行验证，列表页点进分区详情就能看到每个分区的 Leader、ISR 分布；后面要扩容量直接在「增加分区」里填数量，副本调整走「更新副本」，页面还会展示 Topic 的收发统计。

消费组延迟监控实操：积压怎么查

消费组列表支持按组名过滤、按状态（Stable、Empty、Error、Assigning）筛选，一眼看出哪个组不健康。点进「消费详情」看核心的一张表：每个 Topic 每个分区的 end offset 和消费 offset，差值就是积压量——哪个分区滞后多少条，直接对着表看。再点「成员」确认组里实际跑着几个消费者实例，实例数明显少于分区数，基本就是消费能力不足。需要重置位点时，同一详情页支持按时间、earliest、latest 三种方式重置，也能对单个分区指定精确 offset。

按时间检索 Kafka 消息：回溯怎么查

消息菜单下「按时间查询」是排查线上问题最常用的入口：选 Topic 和分区，给定时间戳，就能把那个时间点的消息拉出来，还能按 key、value 做过滤。点开单条消息能看到完整的 key、value、header 和 offset 详情。同一个模块里还支持在线发送测试消息、把某条消息转发到别的 Topic、以及删除指定消息（注意删消息需要集群开启了delete.records.enable）。

用到再配：登录认证就改一行

以下都不是必须项，默认不配也能完整使用。

【可选】登录认证：修改config/application.yml，把认证开关打开：

auth: enable: true # 默认 false expire-hours: 24 # token 过期时间（小时）

内置两个账号：super-admin/123456（可增删用户）和admin/123456，登录后进个人设置改密码，再按需建角色。注意不开启认证时页面不显示「用户」菜单，属正常现象。权限是按钮级的，菜单下具体操作是否可执行由角色权限决定。

【可选】Broker 配置修改：集群菜单下点「Broker 配置」，查看或动态修改 broker 级参数（如log.retention.hours），改完立即生效，不用改 server.properties 重启。

【可选】ACL 权限管理：新增集群时如果填了 SASL_SCRAM 的 ACL 认证配置，导航栏会自动出现「ACL」菜单，可视化管理认证用户（SASL_SCRAM）和授权条目，权限变更实时生效，不用再敲kafka-acls.sh。

【可选】客户端限流：Quota 菜单按用户、client ID、IP 三个维度做速率限流，适合某个下游消费者把集群带宽吃满的场景。

项目基于 Kafka 3.5.0 开发，当前主分支已移除消息同步/集群迁移能力，如需要可看仓库内的集群迁移说明。

源码结构与资源入口

想改代码的话，后端在src/main/java（Spring Boot + Java）和src/main/scala（Kafka Admin 客户端封装），前端是 Vue 工程，页面组件按模块放在ui/src/views下（topic、group、message、acl、quota、op 各一个目录）。用 IDEA 打开时记得把src/main/scala标记为 Sources 并装好 Scala 2.13 插件，细节见开发配置文档。