一、平台介绍
CMAK是由Yahoo开源的Kafka集群管理平台工具;之前叫做Kafka Manager
CMAK(以前称为Kafka Manager)是用于管理Apache Kafka群集的工具。
CMAK支持以下内容:
- 管理多个集群
- 轻松检查群集状态(主题,使用者,偏移量,代理,副本分发,分区分发)
- 运行首选副本选择
- 生成带有选项的分区分配,以选择要使用的代理
- 运行分区的重新分配(基于生成的分配)
- 使用可选的主题配置创建主题(0.8.1.1与0.8.2+具有不同的配置)
- 删除主题(仅在0.8.2+上受支持,并记住在代理配置中设置delete.topic.enable = true)
- 现在,主题列表指示标记为删除的主题(仅在0.8.
原文链接:https://www.dqzboy.com 2+上受支持) - 批量生成多个主题的分区分配,并可以选择要使用的代理
- 批量运行分区的多个主题的重新分配
- 将分区添加到现有主题
- 更新现有主题的配置
- (可选)为代理级别和
文章来源(Source):浅时光博客 主题级别的度量启用JMX轮询。 - (可选)过滤出在Zookeeper中没有id / owner /&offsets /目录的使用者。
GitHub项目地址:
二、安装部署
1、环境要求
- Kafka 0.8.. or 0.9.. or 0.10.. or 0.11..
- Java 11+
2、下载安装
- 下
原文链接:https://www.dqzboy.com 载程序压缩包,并上传至服务器进行解压

- 解压软件包
unzip cmak-3.0.0.5.zip -d /usr/local/
cd /usr/local/
mv cmak-3.0.0.5 cmak
3、修改配置
cd /usr/local/cmak/
cd conf/
vim application.conf

4、启动服务
/usr/local/cmak/bin/cmak -Dconfig.file=/usr/local/cmak/conf/application.conf -Dhttp.port=8090 -java-home /usr/local/jdk-11.0.7
- 参数解
文章来源(Source):浅时光博客 释:-Dconfig.file
: 指明cmak配置文件路径-Dhttp.port
: web监听文章来源(Source):浅时光博客 端口-java-home
: 指定java路径,也可以不指定。这里由于需要用jdk11,而我这台服务器上也安装了jdk8,所以需要指定下路径
- 放置后台运行
nohup /usr/local/cmak/bin/cmak -Dconfig.file=/usr/local/cmak/conf/application.conf -Dhttp.port=8090 -java-home /usr/local/jdk-11.0.7 >/usr/local/cmak/cmakup.log 2>&1 &
三、访问页面
- 浏览器输入:http://ip:8090



如果创建集群出现错误,请参考以下方式解决:
- 在zookeeper 的服务端 启动客户端,手工创建2个目录,就可以正常进行集群创建了
create /kafka-manager/mutex/locks ""
create /kafka-manager/mutex/leases ""
强啊,又有新文章学习了