有人能提供一个如何使用dropwizard lib访问Kafka指标的例子吗?
下面的代码使用yammer metrica访问具有给定指标Name的指标
MetricName metricName = new MetricName("", "", "", "", "kafka.server:type=ZooKeeperClientMetrics,name=ZooKeeperRequestLatencyMs");
Metric m = Metrics.defaultRegistry().allMetrics().get(metricName);
another example of accessing the metrics using yammer
for (Map.Entry<String, SortedMap<MetricName, Metric>> entry : getMetricsRegistry()
.groupedMetrics(MetricPredicate.ALL)
.entrySet()) {
for (Map.Entry<MetricName, Metric> subEntry : entry.getValue().entrySet()) {
final Metric metric = subEntry.getValue();
metric.processWith(this, subEntry.getKey(), epoch);
}
}
Does anybody know what is the equivalent code using dropwizard?
1条答案
按热度按时间ovfsdjhp1#
如果使用
dropwizard-kafka
模块,则已经内置了MetricsReporterhttps://github.com/dropwizard/dropwizard-kafka/blob/4.0.x/src/main/java/io/dropwizard/kafka/metrics/DropwizardMetricsReporter.java