【发布时间】:2019-07-30 08:57:09
【问题描述】:
我正在尝试通过 producer.metrics() api 调用获取 kafka 生产者的所有指标。
我能够获取一些指标,但我无法查看https://kafka.apache.org/20/documentation.html 中提到的所有指标 kafka.producer:type=producer-metrics
我的尝试:
我正在尝试获取属性 record-send-rate 和 record-send-total 的指标。
但我只能看到记录发送速率值,但我无法找到记录发送总计。
final Map<MetricName, ? extends Metric> metricsDisplayMap = producer.metrics();
for (Map.Entry<MetricName, ? extends Metric> entry : metricMap.entrySet()) {
if (metricsNameFilter.contains(entry.getKey().name()) && entry.getKey().group().equalsIgnoreCase("producer-metrics")) {
System.out.print(entry.getKey().name() + " : " + entry.getValue().value() + " <--> " + entry.getKey().group() + " \n ");
}
(1) 我需要打印生产者的所有指标,例如发送的记录数、花费的时间等
(2)另外,我想知道有没有其他方法可以为 kafka 生产者收集指标
(3)KafkaMetricsReporter有什么用,什么时候用?
【问题讨论】:
-
我不认为
record-send-total是组的名称。见github.com/apache/kafka/blob/trunk/clients/src/main/java/org/… -
@mazaneicha - 这是一个错字,组名应该是 producer-metrics 。过滤后,我看不到记录发送率
标签: apache-kafka kafka-consumer-api kafka-producer-api