ghcr.io/kafbat/kafka-ui:bbdf7d4
Kafbat UI
一款多功能、快速且轻量级的Web UI,用于管理Apache Kafka®集群。
文档 • 快速开始 • 社区
AWS Marketplace • ProductHunt
Kafbat UI 是一款免费开源的Web UI,用于监控和管理Apache Kafka集群。
Kafbat UI 是一款简单工具,可让您的数据流可观测,帮助更快发现和排查问题,并提供最佳性能。其轻量级仪表板可轻松跟踪Kafka集群的关键指标——代理、主题、分区、生产和消费情况。
Kafbat UI由Kafbat *开发,自豪地延续了UI Apache Kafka项目的传统。我们的奉献体现在项目的持续演进中,确保在坚持其基础愿景的同时适应现代需求。我们感谢Provectus过去在开创性工作中的支持,这是我们持续创新和奉献的基石。
-
- Kafbat团队由项目 inception 以来的核心贡献者组成,为这一重新启动的项目带来了丰富的经验和见解。
界面
功能
- 主题洞察 – 查看主题基本详情,包括分区数量、复制状态和自定义配置。
- 配置向导 – 直接通过UI设置和配置Kafka集群。
- 多集群管理 – 在统一界面中监控和管理所有Kafka集群。
- 指标仪表板 – 通过精简的轻量级仪表板实时跟踪关键Kafka指标。
- Kafka代理概览 – 检查代理,包括分区分配和控制器状态。
- 消费者组详情 – 分析每个分区的停放偏移量,并监控合并和分区特定的延迟。
- 消息浏览器 – 以JSON、纯文本或Avro编码格式浏览消息。支持实时视图,并通过用户定义的CEL消息过滤器增强功能。
- 动态主题管理 – 使用灵活的实时设置创建和配置新主题。
- 可插拔认证 – 使用OAuth 2.0(GitHub、GitLab、Google)、LDAP或基本认证保护UI。
- 云IAM支持 – 与GCP IAM、Azure IAM和AWS IAM集成,实现云原生身份和访问管理。
- 托管Kafka服务支持 – 全面支持Azure EventHub、Google Cloud Managed Service for Apache Kafka和AWS Managed Streaming for Apache Kafka (MSK)——包括基于服务器和无服务器模式。
- 自定义SerDe插件支持 – 使用内置的序列化器/反序列化器(如AWS Glue和Smile),或创建自己的自定义插件。
- 基于角色的访问控制 – 通过RBAC 管理精细的UI权限。
- 数据脱敏 – 对主题消息中的敏感数据进行模糊处理,以增强隐私和合规性。
- API文档(Swagger UI) - 通过内置Swagger UI访问完整API规范(可通过
SWAGGER_UI_ENABLED变量启用)。 - MCP服务器 - 模型上下文协议服务器
功能概述
点击此处查看功能概述
主题
Kafbat UI让您可以轻松地在浏览器中通过几次点击创建主题,粘贴自己的参数,并在列表中查看主题。
您可以从连接器视图跳转到相应的主题,从主题跳转到消费者(来回切换),以便更方便地导航,包括连接器和主题概览设置。
消息
假设您想为主题生成消息。使用Kafbat UI,您可以通过指定参数并在列表中查看消息,轻松地向Kafka主题发送或写入数据/消息。
模式注册表
支持三种模式类型:Avro®、JSON Schema和Protobuf模式。
在生成Avro/Protobuf编码的消息之前,您需要在模式注册表中为主题添加模式。现在,所有这些步骤都可以通过用户友好的界面轻松完成,只需几次点击。
快速开始
要运行Kafbat UI,您可以使用预构建的Docker镜像,也可以自行构建(或构建jar文件)。
快速启动(演示运行)
docker run -it -p 8080:8080 -e DYNAMIC_CONFIG_ENABLED=true -e SWAGGER_UI_ENABLED=true ghcr.io/kafbat/kafka-ui
然后通过 http://localhost:8080 访问Web UI
此命令足以进行试用。完成后,您可以进行持久化安装。
持久化安装
services:
kafbat-ui:
container_name: kafbat-ui
image: ghcr.io/kafbat/kafka-ui:latest
ports:
- 8080:8080
environment:
DYNAMIC_CONFIG_ENABLED: 'true'
SWAGGER_UI_ENABLED: 'true'
volumes:
- ~/kui/config.yml:/etc/kafkaui/dynamic_config.yaml
请参考我们的配置页面进行进一步的应用配置。
一些有用的配置相关链接
Web UI集群配置向导
配置文件说明
Docker Compose示例
其他配置属性
Helm图表
快速开始
从源码构建
从源码构建快速开始
存活和就绪探针
存活和就绪端点位于 /actuator/health。
信息端点(构建信息)位于 /actuator/info。
配置选项
所有环境变量和配置属性可在此处找到。
贡献
请参考贡献指南;我们将从那里为您提供指导。
支持
由于我们完全独立,团队成员在业余时间贡献力量。您的支持对我们至关重要,如果您希望赞助我们,请查看https://github.com/***/kafbat
技术支持
轩辕镜像配置手册
探索更多轩辕镜像的使用方法,找到最适合您系统的配置方式
Docker 配置
登录仓库拉取
通过 Docker 登录认证访问私有仓库
专属域名拉取
无需登录使用专属域名
K8s Containerd
Kubernetes 集群配置 Containerd
K3s
K3s 轻量级 Kubernetes 镜像加速
Dev Containers
VS Code Dev Containers 配置
Podman
Podman 容器引擎配置
Singularity/Apptainer
HPC 科学计算容器配置
其他仓库配置
ghcr、Quay、nvcr 等镜像仓库
Harbor 镜像源配置
Harbor Proxy Repository 对接专属域名
Portainer 镜像源配置
Portainer Registries 加速拉取
Nexus 镜像源配置
Nexus3 Docker Proxy 内网缓存
系统配置
需要其他帮助?请查看我们的 常见问题Docker 镜像访问常见问题解答 或 提交工单
镜像拉取常见问题
使用与功能问题
配置了专属域名后,docker search 为什么会报错?
docker search 限制
Docker Hub 上有的镜像,为什么在轩辕镜像网站搜不到?
站内搜不到镜像
机器不能直连外网时,怎么用 docker save / load 迁镜像?
离线 save/load
docker pull 拉插件报错(plugin v1+json)怎么办?
插件要用 plugin install
WSL 里 Docker 拉镜像特别慢,怎么排查和优化?
WSL 拉取慢
轩辕镜像安全吗?如何用 digest 校验镜像没被篡改?
安全与 digest
第一次用轩辕镜像拉 Docker 镜像,要怎么登录和配置?
新手拉取配置
轩辕镜像合规吗?轩辕镜像的合规是怎么做的?
镜像合规机制
轩辕镜像支持 docker push 上传本地镜像吗?
不支持 push
错误码与失败问题
docker pull 提示 manifest unknown 怎么办?
manifest unknown
docker pull 提示 no matching manifest 怎么办?
no matching manifest(架构)
镜像已拉取完成,却提示 invalid tar header 或 failed to register layer 怎么办?
invalid tar header(解压)
Docker pull 时 HTTPS / TLS 证书验证失败怎么办?
TLS 证书失败
Docker pull 时 DNS 解析超时或连不上仓库怎么办?
DNS 超时
docker 无法连接轩辕镜像域名怎么办?
域名连通性排查
Docker 拉取出现 410 Gone 怎么办?
410 Gone 排查
出现 402 或「流量用尽」提示怎么办?
402 与流量用尽
Docker 拉取提示 UNAUTHORIZED(401)怎么办?
401 认证失败
遇到 429 Too Many Requests(请求太频繁)怎么办?
429 限流
docker login 提示 Cannot autolaunch D-Bus,还算登录成功吗?
D-Bus 凭证提示
为什么会出现「单层超过 20GB」或 413,无法加速拉取?
413 与超大单层
账号 / 计费 / 权限
用户好评
来自真实用户的反馈,见证轩辕镜像的优质服务