@Override
    public void close() {
        LOGGER.info("Closing Auto Balancer metrics reporter, id={}.", brokerId);
        shutdown = true;
        if (metricsReporterRunner != null) {
            metricsReporterRunner.interrupt();
        }
        if (producer != null) {
            producer.close(PRODUCER_CLOSE_TIMEOUT);
        }
    }
On kafka metric removed

@param metric {@link KafkaMetric}
core/src/main/java/kafka/autobalancer/metricsreporter/AutoBalancerMetricsReporter.java