一、Kafka Manager 簡介
Apache Kafka 是一種高吞吐量、低延遲的分散式發布訂閱消息系統,擁有很強的可擴展性和容錯性,可處理大規模的實時數據。而 Kafka Manager 是一個開源的 Web 管理界面,用於管理和監視多個 Kafka 集群,提供了簡單易用的用戶界面和操作方式。
二、Kafka Manager 安裝
安裝 Java
Kafka Manager 是一個基於 Java 的應用程序,所以在安裝 Kafka Manager 之前,需要先安裝 Java 環境。
$ sudo apt update
$ sudo apt install default-jre
$ java -version
下載 Kafka Manager
從 Kafka Manager 的 GitHub 頁面下載最新的穩定版本,下載地址為:https://github.com/yahoo/kafka-manager/releases
$ wget https://github.com/yahoo/kafka-manager/archive/3.0.0.7.tar.gz
$ tar -xvf 3.0.0.7.tar.gz
$ cd kafka-manager-3.0.0.7
編譯 Kafka Manager
Kafka Manager 需要先進行編譯,然後才能被執行。
$ ./sbt clean dist
三、Kafka Manager 配置
配置 application.conf
Kafka Manager 的主要配置文件為 application.conf,需要根據實際需求進行修改,文件位於 conf 目錄下。如下為一個簡單的配置文件示例:
kafka-manager.zkhosts="localhost:2181"
kafka-manager.features=["KMClusterManagerFeature","KMTopicManagerFeature"]
說明:
– kafka-manager.zkhosts: ZooKeeper 集群地址;
– kafka-manager.features: 啟用的功能特性,包括 “KMClusterManagerFeature” 和 “KMTopicManagerFeature”。
啟動 Kafka Manager
執行以下命令啟動 Kafka Manager:
$ cd target/universal/
$ tar -xvf kafka-manager-3.0.0.7.zip
$ cd kafka-manager-3.0.0.7/bin/
$ ./kafka-manager -Dconfig.file=../../conf/application.conf
四、Kafka Manager 使用
登錄 Kafka Manager
在瀏覽器中輸入 http://localhost:9000,打開 Kafka Manager 的登錄頁面,使用默認的用戶名 admin 和密碼 admin 進行登錄。
設置 Kafka 集群
首先需要設置 Kafka 集群,進入 Cluster 界面,選擇 Add Cluster,填寫必要的信息,例如:
Name: myKafka
Zookeeper Hosts: localhost:2181
Kafka Version: 2.4.0
查看 Kafka Topic
在 Kafka Manager 的 Topics 界面,可以查看和管理 Kafka 中的 Topic,例如:
Name: myTopic
Partitions: 1
Replication Factor: 1
查看 Kafka Consumer Group
在 Kafka Manager 的 Consumer Groups 界面,可以查看和管理 Kafka Consumer Group,例如:
Name: myGroup
Lag: 0
五、Kafka Manager 與 Kafka 集群的一些操作
創建 Kafka Topic
在 Kafka Manager 的 Topics 界面,點擊 Create Topic,填寫 Topic 名稱、Partitions 數量、Replication Factor 等信息進行創建。
刪除 Kafka Topic
在 Kafka Manager 的 Topics 界面,選擇要刪除的 Topic,點擊 Actions->Delete 進行刪除。
增加 Kafka Broker
在 Kafka Manager 的 Cluster 界面,選擇要增加 Broker 的集群,點擊 Add Broker,填寫 Broker 的 Host、Port 等信息進行增加。
刪除 Kafka Broker
在 Kafka Manager 的 Cluster 界面,選擇要刪除 Broker 的集群,從列表中選擇對應的 Broker,點擊 Actions->Remove 。
展示 Kafka Broker 的詳情
在 Kafka Manager 的 Cluster 界面,從列表中選擇對應的 Broker,點擊其名稱,即可查看其詳情。
原創文章,作者:小藍,如若轉載,請註明出處:https://www.506064.com/zh-tw/n/290778.html