Kafka 的 Web UI 之 Kafbat UI

摘要

  • 本文介绍 Kafka 的 Web UI 之 Kafbat UI

  • Kafka官网

  • 本文使用的 Kafka 版本为 3.9.1。Kafka 团队宣布 3.9 会是 最后一个还带有被弃用的 ZooKeeper 模式 的主要版本。以后版本(如 4.0)将完全弃用 ZooKeeper。

  • Kafbat UI 官网,Kafbat UI Github,Kafbat UI 文档

Kafbat UI 简介

  • Kafbat UI 是一个免费的开源 Web 用户界面,用于监控和管理 Apache Kafka 集群。

  • Kafbat UI 是一个简单的工具,使您的数据流变得可观察,帮助更快地发现和排除问题,并提供最佳性能。其轻量级的仪表盘使您能够轻松跟踪 Kafka 集群的关键指标: 包括 Brokers、Topics、Partitions、生产和消费情况。

运行 Kafbat UI

Docker 运行

1
2
3
4
5
6
7
docker run -it -p 8080:8080 \
--name kafka-ui \
-e KAFKA_CLUSTERS_0_NAME=kafka_c01 \
-e KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS=localhost:9092 \
-e TZ=Asia/Shanghai \
-d ghcr.io/kafbat/kafka-ui:latest

Jar 运行

  • Github上下载最新版jar包,要求 jdk 21+

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

# 配置kafka集群,可以同时配置多个,序号从0开始依次递增
export KAFKA_CLUSTERS_0_NAME=kafka_c01
export KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS=localhost:9092
# export KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS=52.82.13.215:9093,52.82.25.87:9093,68.79.17.223:9093

# export KAFKA_CLUSTERS_1_NAME=kafka_c02
# export KAFKA_CLUSTERS_1_BOOTSTRAPSERVERS=remoteIP:9093

# 时区
export TZ=Asia/Shanghai
# 语言
export LANG=zh_CN.UTF-8

# webui访问路径
export SERVER_SERVLET_CONTEXT_PATH=/
# 认证方式,支持NONE(无认证),LOGIN_FORM(登录表单认证)
export AUTH_TYPE=LOGIN_FORM
# 认证用户名密码
export SPRING_SECURITY_USER_NAME=admin
export SPRING_SECURITY_USER_PASSWORD=admin

# jvm参数
export JAVA_OPTS="-Xms512m -Xmx1024m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=256m"
# 启动
jdk21/bin/java --add-opens java.rmi/javax.rmi.ssl=ALL-UNNAMED $JAVA_OPTS -jar api-v1.3.0.jar

访问 Kafbat UI