JMXMetricController.java 文件源码

private Map<String, MeterMetric> getMetricsFromMBean(MBeanServerConnection mBeanServerConnection,
        Optional<String> topic) {
    Map<String, MeterMetric> result = new HashMap<String, MeterMetric>();
    KafkaMetrics metrics = new KafkaMetrics();
    for (String metric : metricName) {
        if (result.containsKey(metric)) {
            result.put(metric, merge(result.get(metric), metrics.getItem(mBeanServerConnection, topic, metric)));
        } else {
            result.put(metric, metrics.getItem(mBeanServerConnection, topic, metric));
        }
    }
    return result;
}