protected void processBrokerMetrics(YammerMetricProcessor.Context context) {
        context.merge(new BrokerMetrics(context.time(), brokerId, brokerRack)
                .put(RawMetricTypes.BROKER_METRIC_VERSION, MetricVersion.LATEST_VERSION.value())
                // TODO: fix latency calculation
                .put(RawMetricTypes.BROKER_APPEND_LATENCY_AVG_MS,
                        TimeUnit.NANOSECONDS.toMillis((long) appendLatencyAvg.derive(
                                StreamOperationStats.getInstance().appendStreamLatency.sum(),
                                StreamOperationStats.getInstance().appendStreamLatency.count())))
                .put(RawMetricTypes.BROKER_MAX_PENDING_APPEND_LATENCY_MS,
                        TimeUnit.NANOSECONDS.toMillis(S3StreamMetricsManager.maxPendingStreamAppendLatency()))
                .put(RawMetricTypes.BROKER_MAX_PENDING_FETCH_LATENCY_MS,
                        TimeUnit.NANOSECONDS.toMillis(S3StreamMetricsManager.maxPendingStreamFetchLatency())));
    }
Send a AutoBalancerMetric to the Kafka topic.

@param ccm the auto balancer metric to send.
core/src/main/java/kafka/autobalancer/metricsreporter/AutoBalancerMetricsReporter.java