diff --git a/src/main/java/com/airbnb/kafka/kafka09/StatsdMetricsReporter.java b/src/main/java/com/airbnb/kafka/kafka09/StatsdMetricsReporter.java index 4ec62981d..a662f8969 100644 --- a/src/main/java/com/airbnb/kafka/kafka09/StatsdMetricsReporter.java +++ b/src/main/java/com/airbnb/kafka/kafka09/StatsdMetricsReporter.java @@ -49,7 +49,6 @@ public class StatsdMetricsReporter implements MetricsReporter { public static final String STATSD_DIMENSION_ENABLED = "external.kafka.statsd.dimension.enabled"; private static final String METRIC_PREFIX = "kafka."; - private static final int POLLING_PERIOD_IN_SECONDS = 10; private boolean enabled; private final AtomicBoolean running = new AtomicBoolean(false); @@ -73,7 +72,7 @@ public void init(List metrics) { kafkaMetrics = new HashMap(); if (enabled) { - startReporter(POLLING_PERIOD_IN_SECONDS); + startReporter(pollingPeriodInSeconds); } else { log.warn("KafkaStatsDReporter is disabled"); }