GitHub地址:
https://github.com/didi/LogiKM
-
下載安裝包
-
解壓安裝包
tar -zxvf kafka-manager-2.4.2.tar.gz
-
創建數據庫
打開解壓好的包可以看到 create_mysql_table.sql


這個是kafka-manager是通過mysql數據庫做元數據管理的, 所以首先我們要准備好mysql,
然后再mysql中運行這個文件
運行命令: source create_mysql_table.sql 會生成所有需要的數據庫和表
注意: 沒有創建用戶,需要我們手動創建用戶並賦權限
GRANT ALL PRIVILEGES ON 數據庫名(查看運行文件后生成的數據庫名就OK了).* TO ‘用戶名'@'%' IDENTIFIED BY '用戶密碼’;
-
配置文件

這就OK了。。。。


-
配置集群


創建完成后點擊名稱進入該物理集群,正常情況下這樣應該就可以了,但是滴滴的這款開源管理工具是可以接入多個集群進行管理的, 所以它是有root用戶和其他普通用戶的,然而普通用戶是看不到物理集群的,
因為滴滴引入了region的概念(應用於集群規模較大的集群,比如有1000台服務器,可以使用region的概念將500台機器放入一個region,另外500台機器放入另一個region,這樣管理起來比較方便)
邏輯集群,普通用戶只能看到邏輯集群 ,因此我們還需要創建region 和邏輯集群。
新增region,視情況而定配置幾個region

新增邏輯集群

此時就可以再集群管理中 看到集群信息了, 然后進入topic管理中也可以看到topic 全部了
進入topic管理中, 選擇一個topic 查看其基本信息中會有實時監控流量,但是因為我們Kafka集群沒有配置JMX 所以顯示看不到

配置Kafka 的JMX監控
需要再kafka每台機器中都進行如下操作
-
kafka-server-start.sh
增加JMX_PORT 端口

-
kafka-run-class.sh

這下徹底OK。