1、拉取最新的kafka manager
git clone https://github.com/yahoo/CMAK.git
2、确保是jdk11
java -version //如果不是安装一下jdk11 wget https://mirrors.huaweicloud.com/java/jdk/11+28/jdk-11_linux-x64_bin.tar.gz tar -zxvf jdk-11_linux-x64_bin.tar.gz //添加环境变量 vim /etc/profile //添加安装jdk11的路径 source /etc/profile
3、创建可部署文件
cd CMAK ./sbt clean dist
4、解压生成的部署文件
cd target/universal unzip cmak-3.0.0.6.zip
5、运行启动kafka manager
cd cmak-3.0.0.6 //可以通过-Dhttp.port=XXXX来指定端口号 //可以通过-java-home指定jdk的路径 nohup ./bin/cmak -Dhttp.port=8222 -java-home /home/work/jdk-11 > 2>&1 /dev/null &
6、遇到的问题
6.1 jdk版本不对，不能生成部署文件
6.2 zk无法连接，重新启动
cd /home/work/data/apache-zookeeper-3.7.0-bin/bin ./zkServer.sh start ./zkServer.sh status ./zkCli.sh -server 10.9.226.71:2181
6.3 kafka连接测试
//查看当前的topic ./kafka-topics.sh --zookeeper localhost:2181 --list //启动生产者 ./kafka-console-producer.sh --bootstrap-server 10.9.226.71:9092 --topic 622a5a86b26b4f5b9fbfa55db8d0bd34__kangguoqing_test_1 //启动消费者 ./kafka-console-consumer.sh --bootstrap-server 10.9.226.71:9092 --topic 622a5a86b26b4f5b9fbfa55db8d0
6.4 如果cmak启动失败的话，看是不是生成了RUNNING_PID文件，如果有的话，把RUNNING_PID文件删除后再重启
