代码之家 › 专栏 › 技术社区 › swagrov

我如何在kafka jmx度量中观察responsesendtimes和consumerlag

jmx apache-kafka

swagrov · 技术社区 · 5 年前

在Kafka代理上,我可以很好地运行此命令:

./kafka-run-class.sh kafka.tools.JmxTool --object-name kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec

但是这些命令失败了,因为“查询对象没有匹配的属性”

./kafka-run-class.sh kafka.tools.JmxTool --object-name 'kafka.server:type=FetcherLagMetrics,name=ConsumerLag,clientId=([-.\w]+),topic=([-.\w]+),partition=([0-9]+)'

和

./kafka-run-class.sh kafka.tools.JmxTool --object-name "kafka.network:type=RequestMetrics,name=ResponseSendTimeMs,request={Produce|FetchConsumer|FetchFollower}"

和

./kafka-run-class.sh kafka.tools.JmxTool --object-name "kafka.network:type=RequestMetrics,name=RequestsPerSec,request=FetchFollower"

如何收集这些指标?

卡夫卡2.2.0版

0 回复 | 直到 5 年前

推荐文章

Toby Daniel C. Sobral · 在sbt native packager中配置“动态”命令行参数

7 年前

Tobi · 将Kafka配置为仅在127.0.0.1上公开JMX

7 年前

Manish Kumar · 在Java中使用JMX读取cassandra矩阵

7 年前

timmy_stapler · 如何为定制处理器定义新的度量标准(并使其在jconsole中可用)?

7 年前

NaiveCoder · DBCP连接池活动连接未关闭

7 年前

Toon · QuickFIXJ MBeanServerInvocationHandler。newProxyInstance参数类型错误

7 年前

Little J · org.apache.tomcat.jdbc.pool。jmx没有出现在JConsole上

7 年前

billc.cn · 使用RMI以本地模式连接到JMX(无端口)

9 年前

Otagamo · 外部与内部JS-MBean值

9 年前

A j · WebSphere MQ是否支持JMX API?

9 年前