@Override
    public void configure(Map<String, ?> configs) {
        super.configure(configs);
        configureSamplingInterval(configs);
        configurePrometheusAdapter(configs);
        configureQueryMap(configs);
    }
@Test(expected = ConfigException.class)
    public void testConfigureWithPrometheusEndpointNegativePortFails() throws Exception {
        Map<String, Object> config = new HashMap<>();
        config.put(PROMETHEUS_SERVER_ENDPOINT_CONFIG, "http://kafka-cluster-1.org:-20");
        addCapacityConfig(config);
        _prometheusMetricSampler.configure(config);
    }