Kafka ui

序

kafka 本身沒有自帶相關的 ui 界面，但是很多時候沒有頁面意味著只有使用命令行進行相關操作如創建 topic、更改 topic 信息、重置 offset 等等。但實際使用中這種效果很差勁，我們一般還是會借助其他軟件，實現對 kafka 的頁面管控。

結合這張圖與實際體驗，推薦大家使用 ui for apache kafka 進行 kafka 的 ui 界面化管理。

kafka-ui 搭建

其實 kafka-ui 是沒有安裝過程的，在 github 上已經打包成了 jar 包，當前最新版本為 0.4,下載地址如下：

https://github.com/provectus/kafka-ui/releases

我們下載最新的 jar 后，放到服務器上如圖：

創建一個 application.yml 文件:

kafka:clusters:- name: kafka3_clusterbootstrapServers: 192.168.111.128:9092,192.168.111.129:9092,192.168.111.130:9092metrics:port: 9094type: JMX- name: OTHER_KAFKA_CLUSTER_NAMEbootstrapServers: 10.10.10.10:9092metrics:port: 9094type: JMXspring:jmx:enabled: truesecurity:user:name: maggotpassword: maggotauth:type: LOGIN_FORM #LOGIN_FORM # DISABLEDserver:port: 10300logging:level:root: INFOcom.provectus: INFOreactor.netty.http.server.AccessLog: INFOmanagement:endpoint:info:enabled: truehealth:enabled: trueendpoints:web:exposure:include: "info,health"

clusters

在 kafka 中配置相關的 kafka 集群，每一個 clusters 為一個集群，需要配置：

• name

設置一個集群名

• bootstrapServers

brokers 連接，針對 kraft 架構，就很方便，不用再配置 zookeeper 相關配置。

• metrics

配置該集群的 JMX 相關配置，如果沒有可省略。（在啟動 kafka 時，啟動命令行前面添加 JMX_PORT=9094 ）

登陸配置

• auth.type

使用 LOGIN_FORM 開啟；或者 DISABLED 關閉認證。如果開啟了，需要 spring.security.user 中配置用戶名與密碼。

• spring.security.user

配置的登陸賬號密碼。

kafka-ui http 端口

• server.port

kafka-ui http 端口。

todo 進行 SASL_SSL 認證配置

kafka-ui 使用

多集群切換

點擊左側進行多集群切換，綠色為集群健康，黃色為警告，紅色為已經掛掉。

集群 Broker 統計信息

所有 broker 總數、controllers 總數、版本號。Partitions 在線數量，URP 數量，在副本數的數量和 OSR 的數量。

下面為每個 broker 的詳細數據信息。

Topic 信息

在 Topics 中，可以看到所有的 topic，也可以進行搜索。

在查詢到自己想看的 topic 后可以點擊 topic name 進行詳細的 topic 查看：

可以通過切換 overview、messages、consumers、settings 進行切換。在左邊有三個點的按鈕都可以操作，

• 其中右上角的對當前 topic 操作，包含：編輯 topic 信息、 清空 topic 數據、重建 topic、刪除 topic。

• 針對每個 broker 也可以清空數據：

創建 topic

在 add custom parameter 中添加額外信息。

Consumers

左邊也可以進行清空狀態操作

總結

以上是生活随笔為你收集整理的Kafka ui 搭建以及使用的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。