gpt4 book ai didi

java - 使用 Metric API 的 Kafka 网络指标

转载 作者:行者123 更新时间:2023-11-30 05:38:52 26 4
gpt4 key购买 nike

有没有办法使用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 指标。有人能指出如何获得相同的结果吗?

最佳答案

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

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

关于java - 使用 Metric API 的 Kafka 网络指标,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56096671/

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com