kafka管理监控系统 CMAK

1 cmak部署

1.1 软件下载

kafka-manager 工具目前改名为cmak,下载地址为：
https://github.com/yahoo/CMAK/releases/tag/3.0.0.5
现在下载最新版本的cmak文件：
cmak-3.0.0.5.zip

1.2 安装jdk11

一定要安装jdk11，否则cmak启动的时候会报错

2021-11-28 20:43:04,928 - [INFO] p.c.s.AkkaHttpServer - Stopping server...
2021-11-28 20:43:04,931 - [ERROR] a.a.ActorSystemImpl - Uncaught error from thread [application-akka.actor.default-dispatcher-14]: controllers/routes has been compiled by a more recent version of the Java Runtime (class file version 55.0), this version of the Java Runtime only recognizes class file versions up to 52.0, shutting down JVM since 'akka.jvm-exit-on-fatal-error' is enabled for ActorSystem[application]
java.lang.UnsupportedClassVersionError: controllers/routes has been compiled by a more recent version of the Java Runtime (class file version 55.0), this version of the Java Runtime only recognizes class file versions up to 52.0
    at java.lang.ClassLoader.defineClass1(Native Method)
    at java.lang.ClassLoader.defineClass(ClassLoader.java:763)
    at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)
    at java.net.URLClassLoader.defineClass(URLClassLoader.java:467)
    at java.net.URLClassLoader.access$100(URLClassLoader.java:73)
    at java.net.URLClassLoader$1.run(URLClassLoader.java:368)
    at java.net.URLClassLoader$1.run(URLClassLoader.java:362)
    at java.security.AccessController.doPrivileged(Native Method)
    at java.net.URLClassLoader.findClass(URLClassLoader.java:361)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424)

我下载的版本是：openjdk-11.0.2_linux-x64_bin.tar.gz
https://www.oracle.com/java/technologies/javase/jdk11-archive-downloads.html

安装

[hadoop@hadoop101 softwares]$ tar -xf openjdk-11.0.2_linux-x64_bin.tar.gz -C /opt/modules/

1.3 解压CMAK

unzip cmak-3.0.0.5.zip -d /opt/modules/

1.4 修改配置文件

修改zookeeper的地址

vim cmak/conf/application.conf

kafka-manager.zkhosts="hadoop101:2181,hadoop102:2181,hadoop103:2181"
cmak.zkhosts="hadoop101:2181,hadoop102:2181,hadoop103:2181"

1.5 启动kafka

开启jmx_port

JMX_PORT=9988 /opt/modules/kafka/bin/kafka-server-start.sh -daemon /opt/modules/kafka/config/server.properties

1.6 启动cmak

# 临时启动
bin/cmak -Dconfig.file=conf/application.conf -java-home /opt/modules/jdk-11.0.2/

# 后台启动
nohup bin/cmak -Dconfig.file=conf/application.conf -java-home /opt/modules/jdk-11.0.2/ &

1.7 页面访问

1.8 创建cluster