使用 Metric API 的 Kafka 网络指标答案

【问题标题】：Kafka Network Metrics using Metric API使用 Metric API 的 Kafka 网络指标
【发布时间】：2019-05-12 06:18:44
【问题描述】：

有什么方法可以使用 Metrics java API 从kafka.network:type=RequestMetrics,name=TotalTimeMs,request={Produce|FetchConsumer|FetchFollower} 获取请求总时间？

使用下面的代码，我可以获得生产者指标。

for (Entry<MetricName, ? extends Metric> entry : producer.metrics().entrySet()) {
    System.out.println(entry.getKey().name() + " : " + entry.getValue().metricValue());
}

但我不确定如何获取 TotalTimeMs 指标。谁能指出如何获得相同的？

【问题讨论】：

标签： java apache-kafka jmx kafka-producer-api

【解决方案1】：

kafka.network:type=RequestMetrics,name=RequestsPerSec,request={Produce|FetchConsumer|FetchFollower} 在代理上可用，而不是来自客户端应用程序。

您必须远程连接到其上公开的 JMX 端口，或者设置 Prometheus 或 Jolokia，例如，通过 HTTP 导出该指标

【讨论】：