24 files changed, 50 insertions, 0 deletions
diff --git a/kafka/metrics/__init__.py b/kafka/metrics/__init__.py
index dd22f53..6055142 100644
--- a/kafka/metrics/__init__.py
+++ b/kafka/metrics/__init__.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .compound_stat import NamedMeasurable
 from .dict_reporter import DictReporter
 from .kafka_metric import KafkaMetric
diff --git a/kafka/metrics/compound_stat.py b/kafka/metrics/compound_stat.py
index 09bc24a..ac92480 100644
--- a/kafka/metrics/compound_stat.py
+++ b/kafka/metrics/compound_stat.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import abc
 
 from kafka.metrics.stat import AbstractStat
diff --git a/kafka/metrics/dict_reporter.py b/kafka/metrics/dict_reporter.py
index 49af604..0b98fe1 100644
--- a/kafka/metrics/dict_reporter.py
+++ b/kafka/metrics/dict_reporter.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import logging
 import threading
 
diff --git a/kafka/metrics/kafka_metric.py b/kafka/metrics/kafka_metric.py
index 75d32a4..9fb8d89 100644
--- a/kafka/metrics/kafka_metric.py
+++ b/kafka/metrics/kafka_metric.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import time
 
 
diff --git a/kafka/metrics/measurable.py b/kafka/metrics/measurable.py
index ef096f3..b06d4d7 100644
--- a/kafka/metrics/measurable.py
+++ b/kafka/metrics/measurable.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import abc
 
 
diff --git a/kafka/metrics/measurable_stat.py b/kafka/metrics/measurable_stat.py
index dba887d..4487adf 100644
--- a/kafka/metrics/measurable_stat.py
+++ b/kafka/metrics/measurable_stat.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import abc
 
 from kafka.metrics.measurable import AbstractMeasurable
diff --git a/kafka/metrics/metric_config.py b/kafka/metrics/metric_config.py
index e30c477..2e55abf 100644
--- a/kafka/metrics/metric_config.py
+++ b/kafka/metrics/metric_config.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import sys
 
 
diff --git a/kafka/metrics/metric_name.py b/kafka/metrics/metric_name.py
index 02068f0..a475d6c 100644
--- a/kafka/metrics/metric_name.py
+++ b/kafka/metrics/metric_name.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import copy
 
 
diff --git a/kafka/metrics/metrics.py b/kafka/metrics/metrics.py
index d02f48d..e9c465d 100644
--- a/kafka/metrics/metrics.py
+++ b/kafka/metrics/metrics.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import logging
 import sys
 import time
diff --git a/kafka/metrics/metrics_reporter.py b/kafka/metrics/metrics_reporter.py
index b48ad0b..d8bd12b 100644
--- a/kafka/metrics/metrics_reporter.py
+++ b/kafka/metrics/metrics_reporter.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import abc
 
 
diff --git a/kafka/metrics/quota.py b/kafka/metrics/quota.py
index 0410e37..4d1b0d6 100644
--- a/kafka/metrics/quota.py
+++ b/kafka/metrics/quota.py
@@ -1,3 +1,6 @@
+from __future__ import absolute_import
+
+
 class Quota(object):
     """An upper or lower bound for metrics"""
     def __init__(self, bound, is_upper):
diff --git a/kafka/metrics/stat.py b/kafka/metrics/stat.py
index c10f3ce..9fd2f01 100644
--- a/kafka/metrics/stat.py
+++ b/kafka/metrics/stat.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import abc
 
 
diff --git a/kafka/metrics/stats/__init__.py b/kafka/metrics/stats/__init__.py
index 15eafd9..ab1fb71 100644
--- a/kafka/metrics/stats/__init__.py
+++ b/kafka/metrics/stats/__init__.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .avg import Avg
 from .count import Count
 from .histogram import Histogram
diff --git a/kafka/metrics/stats/avg.py b/kafka/metrics/stats/avg.py
index 4d0be0a..cfbaec3 100644
--- a/kafka/metrics/stats/avg.py
+++ b/kafka/metrics/stats/avg.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from kafka.metrics.stats.sampled_stat import AbstractSampledStat
 
 
diff --git a/kafka/metrics/stats/count.py b/kafka/metrics/stats/count.py
index 183e4f2..6e0a2d5 100644
--- a/kafka/metrics/stats/count.py
+++ b/kafka/metrics/stats/count.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from kafka.metrics.stats.sampled_stat import AbstractSampledStat
 
 
diff --git a/kafka/metrics/stats/histogram.py b/kafka/metrics/stats/histogram.py
index 42aacdb..ecc6c9d 100644
--- a/kafka/metrics/stats/histogram.py
+++ b/kafka/metrics/stats/histogram.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import math
 
 
diff --git a/kafka/metrics/stats/max_stat.py b/kafka/metrics/stats/max_stat.py
index 8df54d3..08aebdd 100644
--- a/kafka/metrics/stats/max_stat.py
+++ b/kafka/metrics/stats/max_stat.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from kafka.metrics.stats.sampled_stat import AbstractSampledStat
 
 
diff --git a/kafka/metrics/stats/min_stat.py b/kafka/metrics/stats/min_stat.py
index a57c2dd..072106d 100644
--- a/kafka/metrics/stats/min_stat.py
+++ b/kafka/metrics/stats/min_stat.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import sys
 
 from kafka.metrics.stats.sampled_stat import AbstractSampledStat
diff --git a/kafka/metrics/stats/percentile.py b/kafka/metrics/stats/percentile.py
index 723b9e6..3a86a84 100644
--- a/kafka/metrics/stats/percentile.py
+++ b/kafka/metrics/stats/percentile.py
@@ -1,3 +1,6 @@
+from __future__ import absolute_import
+
+
 class Percentile(object):
     def __init__(self, metric_name, percentile):
         self._metric_name = metric_name
diff --git a/kafka/metrics/stats/percentiles.py b/kafka/metrics/stats/percentiles.py
index 84e7160..b55c5ac 100644
--- a/kafka/metrics/stats/percentiles.py
+++ b/kafka/metrics/stats/percentiles.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from kafka.metrics import AnonMeasurable, NamedMeasurable
 from kafka.metrics.compound_stat import AbstractCompoundStat
 from kafka.metrics.stats import Histogram
diff --git a/kafka/metrics/stats/rate.py b/kafka/metrics/stats/rate.py
index 3ce2e74..810c543 100644
--- a/kafka/metrics/stats/rate.py
+++ b/kafka/metrics/stats/rate.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from kafka.metrics.measurable_stat import AbstractMeasurableStat
 from kafka.metrics.stats.sampled_stat import AbstractSampledStat
 
diff --git a/kafka/metrics/stats/sampled_stat.py b/kafka/metrics/stats/sampled_stat.py
index ca0db69..c41b14b 100644
--- a/kafka/metrics/stats/sampled_stat.py
+++ b/kafka/metrics/stats/sampled_stat.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import abc
 
 from kafka.metrics.measurable_stat import AbstractMeasurableStat
diff --git a/kafka/metrics/stats/sensor.py b/kafka/metrics/stats/sensor.py
index 72bacfc..ca9979b 100644
--- a/kafka/metrics/stats/sensor.py
+++ b/kafka/metrics/stats/sensor.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import threading
 import time
 
diff --git a/kafka/metrics/stats/total.py b/kafka/metrics/stats/total.py
index 76a82d8..5b3bb87 100644
--- a/kafka/metrics/stats/total.py
+++ b/kafka/metrics/stats/total.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from kafka.metrics.measurable_stat import AbstractMeasurableStat