返回 导航

大数据

hangge.com

CMAK - 开源Kafka集群监控管理工具安装使用详解

作者:hangge | 2024-06-17 08:30

1,CMAK 介绍

(1)CMAK 是目前最受欢迎的 Kafka 集群管理工具,最早由雅虎开源(原名为 KafkaManager
(2)通过 CMAK 用户可以在 Web 界面上操作 Kafka 集群,可以轻松检查集群状态(TopicConsumerOffsetBrokersReplicaPartition

2,下载安装包

(1)首先访问 CMAK GitHub 主页(点击访问),选择合适的版本进行下载:
注意:由于我这里下载的 cmak-3.0.0.6.zip 是在 java11 这个版本下编译的,所以在运行的时候也需要使用 java11 这个版本。服务器如何安装 JDK11 可以参考我之前写的文章(点击查看
wget https://github.com/yahoo/CMAK/releases/download/3.0.0.6/cmak-3.0.0.6.zip

(2)然后执行如下命令解压压缩包:
提示:如果执行时报找不到 unzip 命令,可以执行 yum install -y unzip 进行在线安装。
unzip cmak-3.0.0.6.zip

3,修改 CMAK 配置

(1)修改 conf 目录下的 application.conf 文件:
vi conf/application.conf

(2)只需要在里面增加一行 cmak.zkhosts 参数的配置即可,指定 zookeeper 的地址:
注意:在这里指定 zookeeper 地址主要是为了让 CMAK 在里面保存数据,这个 zookeeper 地址不一定是 kafka 集群使用的那个 zookeeper 集群,随便哪个 zookeeper 集群都可以。
cmak.zkhosts="node1:2181,node1:2181,node1:2181"

4,修改 kafka 启动配置

(1)想要在 CMAK 中查看 kafka 的一些指标信息,在启动 kafka 的时候需要指定 JMX_PORT。首先所有节点下执行如下命令停止 kafka 集群:
bin/kafka-server-stop.sh

(2)然后再执行如下命令重新启动 kafka 集群,启动时指定 JXM_PORT
JMX_PORT=9988 bin/kafka-server-start.sh -daemon config/server.properties

5,启动 cmak

(1)进入 cmak 目录,执行如下命令启动 cmak
bin/cmak -Dconfig.file=conf/application.conf -Dhttp.port=9001

(2)如果想把 cmak 放在后台执行的话需要添加上 nohup &
nohup bin/cmak -Dconfig.file=conf/application.conf -Dhttp.port=9001 &

6,访问 cmak

使用浏览器访问 http://服务器IP:9001 即可打开 cmak 界面:

7,操作 CMAK

(1)添加集群
  • 填写集群信息,然后点击 Save 按钮保存即可:

(2)最后进来是这样的:

(3)查看 kafka 集群的所有 broker 信息:

(4)查看 kafka 集群的所有 topic 信息:

(5)查看某一个 topic 的详细信息:


(6)点击 topic 的消费者信息是可以进来查看的:

(7)创建一个 topic

(8)给 topic 增加分区:
评论

全部评论(0)

回到顶部