我尝试用jmxmbean监视kafka,以获取字节消耗率的指标
所以我写下命令:
JMX_PORT= bin/kafka-run-class.sh kafka.tools.JmxTool --object-name kafka.consumer:type=consumer-fetch-manager-metrics,client-id="([-.w]+)"
我也试过了
JMX_PORT= bin/kafka-run-class.sh kafka.tools.JmxTool --object-name kafka.consumer:type=consumer-fetch-manager-metrics,client-id="*"
但每次我在第一个命令中都会出现同样的错误
No matched attributes for the queried objects ArrayBuffer(kafka.consumer:type=consumer-fetch-manager-metrics,client-id=([-.\w]+)).
第二个命令呢
Exception in thread "main" java.lang.NullPointerException
at kafka.tools.JmxTool$.main(JmxTool.scala:194)
at kafka.tools.JmxTool.main(JmxTool.scala)
我应该怎么写这个命令??
暂无答案!
目前还没有任何答案,快来回答吧!