CMAK(KafkaManager)对接MRS_3.1.0集群

一、    MRS集群适配

提示：此步骤不操作也可以对接，只不过CMAK页面点击开启jmx后，CMAK后台会一致报错，另外CMAK页面上的指标刷新不及时。
1.    调整MRS Broker实例JMX监听的IP地址
登录MRS Manager界面，如下修改配置项KAFKA_JMX_IP的值为${BROKER_IP}，并保存。

2.    调整Kafka Broker实例的jmx地址
1）登录MRS Manager界面，在主机管理中查看带五角星节点的IP。
 

2）用xshell等工具登录上面带五角星的两个节点，参考如下命令修改配置文件。
vim /opt/Bigdata/components/FusionInsight_HD_8.1.2.2/Kafka/configurations.xml
搜索关键词：<name>KAFKA_RMI_NAME</name>，并按照下图进行修改。
 

3）在带实心五角星的节点执行如下命令，重启manager的controller服务(manager页面会短暂时间不能显示，不影响组件业务)

su - omm 
/opt/Bigdata/om-server/om/sbin/restart-controller.sh 

3.    滚动重启Kafka
在业务低峰期，登录MRS Manager界面，如下滚动重启Kafka服务
 

二、    安装CMAK

1.    下载CMAK
登录cmak官网下载需要的版本包：https://sourceforge.net/projects/cmak.mirror/
     
2.    安装CMAK
1)    解包安装
unzip cmak-3.0.0.5.zip
2)    修改配置文件
如下，编辑配置 conf/application.conf，配置zookeeper地址，开启登录认证及用户名和密码；

cmak.zkhosts="zk1:2181,zk2:2181,zk3:2181"
basicAuthentication.enabled=true
basicAuthentication.username="admin"
basicAuthentication.password="passwordxxx"

3)    在bin的同级目录下创建启动脚本start.sh，脚本内容如下：

#!/bin/bash
  
export PATH=/opt/Bigdata/common/runtime/jdk-11.0.9/bin:$PATH
export JAVA_HOME=/opt/Bigdata/common/runtime/jdk-11.0.9

bin/cmak -Dconfig.file=./conf/application.conf -Dhttp.port=8089 > ./logs/start.log 2>&1 &

注：CMAK要求JDK版本必须是JDK11+，需要设置JDK11环境变量，本文档直接使用的是MRS集群的JDK，建议客户在集群外节点安装cmak并安装jdk11.

4)    启动CMAK

sh start.sh 

三、    CMAK对接Kafka

1.    登录CMAK
在安全组中放开CMAK的端口访问限制，并给ECS绑定EIP，访问CMAK页面：http://xxx.xxx.xxx.xxx:8089/

2.    对接MRS Kakfa
1）在CMAK上添加kafka集群，可以同时对接多套集群。
 

2）如下，对接完成后可以方便的使用CMAK对kafka进行管理维护。