Kafka Console UI5分钟怎么把轻量级 Kafka 可视化管理平台跑起来【免费下载链接】kafka-console-ui一款快捷易用的轻量级kafka可视化管理平台项目地址: https://gitcode.com/gh_mirrors/ka/kafka-console-uiKafka 集群排查还得敲命令行脚本的时候Kafka Console UI 用浏览器替代了大部分kafka-topics.sh操作。它是一款轻量级 Kafka 可视化管理平台多集群、Topic、消费组、消息查询都能在页面上完成下载即用。5分钟跑起来Windows 和 Linux 的启动差异拿到 kafka-console-ui.zip 安装包后两条路Windows解压后进入bin目录JDK 高于 1.8 双击start.batJDK 1.8 双击start_jdk8.batPowerShell 用户跑start.ps1。停止服务直接关掉命令行窗口就行。Linux / Macunzip 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/javaSpring Boot Java和src/main/scalaKafka Admin 客户端封装前端是 Vue 工程页面组件按模块放在ui/src/views下topic、group、message、acl、quota、op 各一个目录。用 IDEA 打开时记得把src/main/scala标记为 Sources 并装好 Scala 2.13 插件细节见开发配置文档。源码打包说明sh package.sh一条命令出安装包Docker 部署容器化部署与数据持久化ACL 配置说明老版本看不到 ACL 菜单的排查源码获取git clone https://gitcode.com/gh_mirrors/ka/kafka-console-ui社区使用问题或需求直接提 issueREADME 里也留了作者微信群二维码跑起来之后先建个集群切过去再打开 Topic 页面看看你那个集群里到底有什么。【免费下载链接】kafka-console-ui一款快捷易用的轻量级kafka可视化管理平台项目地址: https://gitcode.com/gh_mirrors/ka/kafka-console-ui创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考