CMAK - 开源Kafka集群监控管理工具安装使用详解
作者:hangge | 2024-06-17 08:30
1,CMAK 介绍
(1)CMAK 是目前最受欢迎的 Kafka 集群管理工具,最早由雅虎开源(原名为 KafkaManager)
(2)通过 CMAK 用户可以在 Web 界面上操作 Kafka 集群,可以轻松检查集群状态(Topic、Consumer、Offset、Brokers、Replica、Partition)
2,下载安装包
注意:由于我这里下载的 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 界面:
![](http://hangge.com/blog_uploads/202402/2024022315390438768.png)
7,操作 CMAK
(1)添加集群
![](http://hangge.com/blog_uploads/202402/2024022315423869032.png)
- 填写集群信息,然后点击 Save 按钮保存即可:
![](http://hangge.com/blog_uploads/202402/2024022315471620792.png)
(2)最后进来是这样的:
![](http://hangge.com/blog_uploads/202402/2024022315504913208.png)
(3)查看 kafka 集群的所有 broker 信息:
![](http://hangge.com/blog_uploads/202402/2024022315520729883.png)
(4)查看 kafka 集群的所有 topic 信息:
![](http://hangge.com/blog_uploads/202402/2024022315571368217.png)
(5)查看某一个 topic 的详细信息:
![](http://hangge.com/blog_uploads/202402/2024022315580398303.png)
![](http://hangge.com/blog_uploads/202402/2024022315590062395.png)
(6)点击 topic 的消费者信息是可以进来查看的:
![](http://hangge.com/blog_uploads/202402/2024022316002432103.png)
(7)创建一个 topic:
![](http://hangge.com/blog_uploads/202402/2024022315595410961.png)
(8)给 topic 增加分区:
![](http://hangge.com/blog_uploads/202402/2024022316022493728.png)
全部评论(0)