卡夫卡生产者指标

我正在使用我的 Intellij IDE 在本地机器上运行 Kafka 生产者,生产者将产生一百万条记录。这样做时,我想通过以下方式捕获生产者指标:

http://img2.mukewang.com/636ca46a000186d406530065.jpg

我知道 kafka 的 JMX 端口,我确实尝试将 Kafka JMX 端口设置为 9999。但我不确定我们是否可以按照我期望的上述方式使用 JConsole 或 JVisualVM 获取指标。

任何人都可以就如何实现这一点提出任何想法吗?


慕丝7291255
浏览 93回答 1
1回答

慕沐林林

除了 JMX,官方的 Kafka 客户端还通过 Java API 公开他们的指标,请参阅metrics()检索它们的方法。例如,要打印所有指标的名称和值:for&nbsp;(Entry<MetricName,&nbsp;?&nbsp;extends&nbsp;Metric>&nbsp;entry&nbsp;:&nbsp;producer.metrics().entrySet())&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;System.out.println(entry.getKey().name()&nbsp;+&nbsp;"&nbsp;:&nbsp;"&nbsp;+&nbsp;entry.getValue().metricValue());}在所有指标中,您可能对outgoing-byte-rate和request-total感兴趣request-rate。
打开App,查看更多内容
随时随地看视频慕课网APP

相关分类

Java