@Override
    public void validateReconfiguration(Map<String, ?> configs) throws ConfigException {
        Map<String, Object> objectConfigs = new HashMap<>(configs);
        try {
            if (configs.containsKey(AutoBalancerMetricsReporterConfig.AUTO_BALANCER_METRICS_REPORTER_INTERVAL_MS_CONFIG)) {
                long intervalMs = ConfigUtils.getLong(objectConfigs, AutoBalancerMetricsReporterConfig.AUTO_BALANCER_METRICS_REPORTER_INTERVAL_MS_CONFIG);
                if (intervalMs <= 0) {
                    throw new ConfigException(AutoBalancerMetricsReporterConfig.AUTO_BALANCER_METRICS_REPORTER_INTERVAL_MS_CONFIG, intervalMs);
                }
            }
        } catch (Exception e) {
            throw new ConfigException("Reconfiguration validation error " + e.getMessage());
        }

    }
On kafka metric removed

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