public void sendAutoBalancerMetric(AutoBalancerMetrics ccm) {
        ProducerRecord<String, AutoBalancerMetrics> producerRecord =
                new ProducerRecord<>(Topic.AUTO_BALANCER_METRICS_TOPIC_NAME, null, ccm.time(), ccm.key(), ccm);
        if (LOGGER.isDebugEnabled()) {
            LOGGER.debug("Sending auto balancer metric {}.", ccm);
        }
        producer.send(producerRecord, (recordMetadata, e) -> {
            if (e != null) {
                numMetricSendFailure++;
                if (System.currentTimeMillis() - lastErrorReportTime > 10000) {
                    lastErrorReportTime = System.currentTimeMillis();
                    LOGGER.warn("Failed to send auto balancer metric", e);
                }
            }
        });
    }
Send a AutoBalancerMetric to the Kafka topic.

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