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

        Set<String> topics = new HashSet<>(Arrays.asList(TEST_TOPIC, TEST_TOPIC_WITH_DOT));
        for (String topic: topics) {
            setUp();
            _prometheusMetricSampler.configure(config);
            MetricSamplerOptions metricSamplerOptions = buildMetricSamplerOptions(topic);
            _prometheusMetricSampler._prometheusAdapter = _prometheusAdapter;

            for (RawMetricType rawMetricType : _prometheusQueryMap.keySet()) {
                setupPrometheusAdapterMock(rawMetricType, buildBrokerResults(),
                    buildTopicResults(topic), buildPartitionResults(topic));
            }
            replay(_prometheusAdapter);
            MetricSampler.Samples samples = _prometheusMetricSampler.getSamples(metricSamplerOptions);

            assertSamplesValid(samples, topic);
            verify(_prometheusAdapter);
        }
    }