苏州园区公积金管理中心官网,常州网站建设方案优化,中国建设工程信息网一体化平台,网站开发项目文档众所周知#xff08;反正不管你知不知道#xff09;#xff0c;kafka-maneger更名了#xff0c;现在叫cmak#xff01;原因是什么呢#xff1f;据不可靠小道信息说#xff0c;原kafka-manager这个名字涉及到kafka商标使用问题#xff0c;应该是被律师函警告了#xff… 众所周知反正不管你知不知道kafka-maneger更名了现在叫cmak原因是什么呢据不可靠小道信息说原kafka-manager这个名字涉及到kafka商标使用问题应该是被律师函警告了所以就换名了 1.下载地址
https://github.com/yahoo/CMAK 下载后解压后如上图
注本次下载最新版本包之前的老版本下载后还需要自己编译代码然后再部署使用新版不用根本不用
2.解压缩后将解压包放到合适的位置然后修开配置文件application.conf 修改如下 红框中的改成自己的集群地址就OK了如果是本机部署直接写本机ip
注kafka-manager.zkhosts后续会废弃掉可以注释掉只保留cmak.zkhosts配置 3.启动cmak
进入目录cmak-3.0.0.6/bin下sh cmak
启动成功 4.进入平台
地址http://172.30.19.168:9000/ 5. 添加add clusters 参数添加 然后保存就行了
保存完就可以看到下图红框的内容第一次部署是没有红框内容的只有添加完clusters才会出现 6.愉快的使用 7.启动日志报错Failed to get broker metrics for BrokerIdentity(0,localhost,-1,false,true,Map(PLAINTEXT - 9092))
如果报错会影响Mwtrics模块没数据 报错信息
2024-07-02 19:38:12,373 - [ERROR] - from kafka.manager.actor.cluster.BrokerViewCacheActor in kafka-manager-system-akka.actor.default-dispatcher-8
Failed to get broker metrics for BrokerIdentity(0,localhost,-1,false,true,Map(PLAINTEXT - 9092))
java.lang.IllegalArgumentException: requirement failed: No jmx port but jmx polling enabled!at scala.Predef$.require(Predef.scala:281)at kafka.manager.jmx.KafkaJMX$.doWithConnection(KafkaJMX.scala:39)at kafka.manager.actor.cluster.BrokerViewCacheActor.$anonfun$updateBrokerMetrics$3(BrokerViewCacheActor.scala:359)at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)at scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)at scala.util.Success.$anonfun$map$1(Try.scala:255)at scala.util.Success.map(Try.scala:213)at scala.concurrent.Future.$anonfun$map$1(Future.scala:292)at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)at java.base/java.lang.Thread.run(Thread.java:834)2024-07-02 19:38:12,373 - [ERROR] - from kafka.manager.actor.cluster.BrokerViewCacheActor in kafka-manager-system-akka.actor.default-dispatcher-8
Failed to get broker topic segment metrics for BrokerIdentity(0,localhost,-1,false,true,Map(PLAINTEXT - 9092))
java.lang.IllegalArgumentException: requirement failed: No jmx port but jmx polling enabled!at scala.Predef$.require(Predef.scala:281)at kafka.manager.jmx.KafkaJMX$.doWithConnection(KafkaJMX.scala:39)at kafka.manager.actor.cluster.BrokerViewCacheActor.$anonfun$updateBrokerTopicPartitionsSize$3(BrokerViewCacheActor.scala:383)at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)at scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)at scala.util.Success.$anonfun$map$1(Try.scala:255)at scala.util.Success.map(Try.scala:213)at scala.concurrent.Future.$anonfun$map$1(Future.scala:292)at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
8.解决方案
在kafka-server-start.sh中开头添加一行代码然后重启kafka报错解决了
export JMX_PORT9999 kafka-server-start.sh 路径../kafka/3.7.0/libexec/bin
如果忘记kafka安装路径可以通过以下方式
1.通过whereis kafka-server-start 命令找到命令目录 2.cd 路径如cd /opt/homebrew/bin/
3.在/opt/homebrew/bin/目录找到kafka-server-start
4.cd ../Cellar/kafka/3.7.0/bin/ 然后找到kafka-server-start
5.cat kafka-server-start 查看命令的执行位置,我们会发现实际执行是
/opt/homebrew/Cellar/kafka/3.7.0/libexec/bin/kafka-server-start.sh 6.vim /opt/homebrew/Cellar/kafka/3.7.0/libexec/bin/kafka-server-start.sh 然后添加export JMX_PORT9999
