From 683fb017733626fde5b08b24f91d0e0bef173594 Mon Sep 17 00:00:00 2001
From: Deividas <deividas@Deividass-MacBook-Pro.local>
Date: Thu, 7 Jun 2018 15:23:08 +0300
Subject: [PATCH] fix polling interval to come from config

---
 .../java/com/airbnb/kafka/kafka09/StatsdMetricsReporter.java   | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

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<KafkaMetric> metrics) {
     kafkaMetrics = new HashMap<String, KafkaMetric>();
 
     if (enabled) {
-      startReporter(POLLING_PERIOD_IN_SECONDS);
+      startReporter(pollingPeriodInSeconds);
     } else {
       log.warn("KafkaStatsDReporter is disabled");
     }