安装和使用cmak（原名为kafka manager）

一、安装kafka manager

1.1 安装之前先确保有java11环境

yum install java-11-openjdk
yum install java-11-openjdk-devel
sudo alternatives --config java//选择安装的java11

Java -version确认已经切换版本成功，要不centos 7默认自带的是java8 java1.8.

1.2 下载kafka manager

wget https://github.com/yahoo/CMAK/archive/3.0.0.4.tar.gz
tar -zxvf kafka-manager-3.0.0.4.tar.gz
cd CMAK-3.0.0.4/

1.3 安装sbt编译工具

curl https://bintray.com/sbt/rpm/rpm | sudo tee /etc/yum.repos.d/bintray-sbt-rpm.repo
sudo yum install sbt

1.4 编译kafka manager

在cd CMAK-3.0.0.4/目录执行

sbt clean dist

需要等待一段时间，编译完成之后

1.5 运行kafka manager

/data/mariolu/CMAK-3.0.0.4/target/universal/

会产生 cmak-3.0.0.4.zip ，解压这个包

修改conf/application.conf

 #cmak.zkhosts="kafka-manager-zookeeper:2181"
 cmak.zkhosts="localhost:2181"//kafka的服务地址，需要根据真实地址填写

再进入bin目录, 执行cmak

 ./bin/cmak -Dhttp.port=10010

这样既可以启动kafka manager，然后在浏览器输入ip:10010可以看到kafka的配置网站

二、使用kafka manager

2.1 创建cluster

填入cluster name和cluster zookeeper hosts，然后其他基本上按照默认值或者错误提示配置。

图1 新建集群

创建成功

图2 创建集群成功

2.2 创建topic

填入topic名字和分片数和复制i备份数

图3 创建topic

创建成功

图4 创建成功

2.3 topic的概况如下

图5 topic列表

• Brokers Spread：看作broker使用率，如kafka集群9个broker，某topic有7个partition，则broker spread: 7 / 9 = 77%
• Broker skew（broker的分配倾斜度）,衡量broker分配的不均衡性。broker的partition数超过平均的partiition，则该broker算失衡。失衡的broker/所有的broker = 失衡倾斜度

图6 topic概括

2.4 broker的概括如下

图7 broker概括

2.5 分片信息

此外还可以看到其他比如消费者信息，分片信息等等，甚至可以操作这些分片和broker的重分配

图8 分片消息

图7 分片信息（二）

给topic加分片

图8 加分片

图9 加分片成功

还有其他可以操作分片的选项

图10 操作分片选项

分片重分配

图11 分片重分配