如何使用 dropwizard 库访问 kafka 指标数据

Question

有人可以提供一个如何使用 dropwizard lib 访问 kafka 指标的示例吗？

下面的代码使用 yammer metrica 访问具有给定指标名称的指标

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? 

Answer 1

如果你使用

dropwizard-kafka

模块，已经有一个内置的MetricsReporter

https://github.com/dropwizard/dropwizard-kafka/blob/4.0.x/src/main/java/io/dropwizard/kafka/metrics/DropwizardMetricsReporter.java