使用度量API的java Kafka网络度量

Question

是否有任何方法可以使用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度量。 有人能指出如何得到同样的结果吗

Answer 1

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

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