@Override
    public void processMeter(MetricName metricName, Metered metered, Context context) {
        if (MetricsUtils.isInterested(metricName)) {
            if (LOG.isTraceEnabled()) {
                LOG.trace("Processing metric {} of type Meter.", metricName);
            }
            double value;
            if (context.reportingInterval().toMillis() <= TimeUnit.MINUTES.toMillis(1)) {
                value = metered.oneMinuteRate();
            } else if (context.reportingInterval().toMillis() <= TimeUnit.MINUTES.toMillis(5)) {
                value = metered.fiveMinuteRate();
            } else {
                value = metered.fifteenMinuteRate();
            }
            AutoBalancerMetrics ccm = MetricsUtils.toAutoBalancerMetric(context.time(),
                    context.brokerId(),
                    context.brokerRack(),
                    metricName,
                    value);
            context.merge(ccm);
        }
    }
This class was modified based on Cruise Control: com.linkedin.kafka.cruisecontrol.metricsreporter.metric.YammerMetricProcessor.
core/src/main/java/kafka/autobalancer/metricsreporter/metric/YammerMetricProcessor.java