Always absolute_importabsolute_import

55 files changed, 113 insertions, 0 deletions

diff --git a/kafka/__init__.py b/kafka/__init__.py
index 6b2ba97..03a4924 100644
--- a/kafka/__init__.py
+++ b/kafka/__init__.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 __title__ = 'kafka'
 from .version import __version__
 __author__ = 'Dana Powers'
diff --git a/kafka/client.py b/kafka/client.py
index 0078e52..247905a 100644
--- a/kafka/client.py
+++ b/kafka/client.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import collections
 import copy
 import functools
diff --git a/kafka/common.py b/kafka/common.py
index 5761f72..15e88eb 100644
--- a/kafka/common.py
+++ b/kafka/common.py
@@ -1,2 +1,4 @@
+from __future__ import absolute_import
+
 from kafka.structs import *
 from kafka.errors import *
diff --git a/kafka/conn.py b/kafka/conn.py
index 42bfa60..03c445e 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import collections
 import copy
 import errno
diff --git a/kafka/consumer/__init__.py b/kafka/consumer/__init__.py
index 8041537..36c8ff0 100644
--- a/kafka/consumer/__init__.py
+++ b/kafka/consumer/__init__.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .simple import SimpleConsumer
 from .multiprocess import MultiProcessConsumer
 from .group import KafkaConsumer
diff --git a/kafka/context.py b/kafka/context.py
index d6c15fe..1ebc71d 100644
--- a/kafka/context.py
+++ b/kafka/context.py
@@ -1,6 +1,8 @@
 """
 Context manager to commit/rollback consumer offsets.
 """
+from __future__ import absolute_import
+
 from logging import getLogger
 
 from kafka.errors import check_error, OffsetOutOfRangeError
diff --git a/kafka/coordinator/assignors/abstract.py b/kafka/coordinator/assignors/abstract.py
index 773280a..a1fef38 100644
--- a/kafka/coordinator/assignors/abstract.py
+++ b/kafka/coordinator/assignors/abstract.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import abc
 import logging
 
diff --git a/kafka/coordinator/assignors/range.py b/kafka/coordinator/assignors/range.py
index 861c8d2..cbf411e 100644
--- a/kafka/coordinator/assignors/range.py
+++ b/kafka/coordinator/assignors/range.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import collections
 import logging
 
diff --git a/kafka/coordinator/assignors/roundrobin.py b/kafka/coordinator/assignors/roundrobin.py
index 523a332..a068b3f 100644
--- a/kafka/coordinator/assignors/roundrobin.py
+++ b/kafka/coordinator/assignors/roundrobin.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import collections
 import itertools
 import logging
diff --git a/kafka/coordinator/heartbeat.py b/kafka/coordinator/heartbeat.py
index 648cb1f..fddf298 100644
--- a/kafka/coordinator/heartbeat.py
+++ b/kafka/coordinator/heartbeat.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import copy
 import time
 
diff --git a/kafka/errors.py b/kafka/errors.py
index a517ea7..c005bf8 100644
--- a/kafka/errors.py
+++ b/kafka/errors.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import inspect
 import sys
 
diff --git a/kafka/future.py b/kafka/future.py
index 4a3af47..d0f3c66 100644
--- a/kafka/future.py
+++ b/kafka/future.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import functools
 import logging
 
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
 
 
diff --git a/kafka/partitioner/__init__.py b/kafka/partitioner/__init__.py
index 5b6ac2d..9ce6ade 100644
--- a/kafka/partitioner/__init__.py
+++ b/kafka/partitioner/__init__.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .roundrobin import RoundRobinPartitioner
 from .hashed import HashedPartitioner, Murmur2Partitioner, LegacyPartitioner
 
diff --git a/kafka/partitioner/base.py b/kafka/partitioner/base.py
index 857f634..00f7be3 100644
--- a/kafka/partitioner/base.py
+++ b/kafka/partitioner/base.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 
 class Partitioner(object):
     """
diff --git a/kafka/partitioner/default.py b/kafka/partitioner/default.py
index 358efeb..79205b6 100644
--- a/kafka/partitioner/default.py
+++ b/kafka/partitioner/default.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import random
 
 from .hashed import murmur2
diff --git a/kafka/partitioner/roundrobin.py b/kafka/partitioner/roundrobin.py
index 6439e53..d244353 100644
--- a/kafka/partitioner/roundrobin.py
+++ b/kafka/partitioner/roundrobin.py
@@ -1,7 +1,10 @@
+from __future__ import absolute_import
+
 from itertools import cycle
 
 from .base import Partitioner
 
+
 class RoundRobinPartitioner(Partitioner):
     """
     Implements a round robin partitioner which sends data to partitions
diff --git a/kafka/producer/__init__.py b/kafka/producer/__init__.py
index 3664eb2..5213fe8 100644
--- a/kafka/producer/__init__.py
+++ b/kafka/producer/__init__.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .kafka import KafkaProducer
 from .simple import SimpleProducer
 from .keyed import KeyedProducer
diff --git a/kafka/protocol/__init__.py b/kafka/protocol/__init__.py
index 7b2a2f3..2a269a5 100644
--- a/kafka/protocol/__init__.py
+++ b/kafka/protocol/__init__.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .legacy import (
     create_message, create_gzip_message,
     create_snappy_message, create_message_set,
diff --git a/kafka/protocol/abstract.py b/kafka/protocol/abstract.py
index 160678f..2de65c4 100644
--- a/kafka/protocol/abstract.py
+++ b/kafka/protocol/abstract.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import abc
 
 
diff --git a/kafka/protocol/admin.py b/kafka/protocol/admin.py
index 706bc3a..12181d7 100644
--- a/kafka/protocol/admin.py
+++ b/kafka/protocol/admin.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .struct import Struct
 from .types import Array, Bytes, Int16, Schema, String
 
diff --git a/kafka/protocol/api.py b/kafka/protocol/api.py
index 0c23437..7779aac 100644
--- a/kafka/protocol/api.py
+++ b/kafka/protocol/api.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .struct import Struct
 from .types import Int16, Int32, String, Schema
 
diff --git a/kafka/protocol/commit.py b/kafka/protocol/commit.py
index 90a3b76..69201be 100644
--- a/kafka/protocol/commit.py
+++ b/kafka/protocol/commit.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .struct import Struct
 from .types import Array, Int16, Int32, Int64, Schema, String
 
diff --git a/kafka/protocol/fetch.py b/kafka/protocol/fetch.py
index 0542ad2..7df6627 100644
--- a/kafka/protocol/fetch.py
+++ b/kafka/protocol/fetch.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .message import MessageSet
 from .struct import Struct
 from .types import Array, Int16, Int32, Int64, Schema, String
diff --git a/kafka/protocol/group.py b/kafka/protocol/group.py
index c49cfc8..98715f3 100644
--- a/kafka/protocol/group.py
+++ b/kafka/protocol/group.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .struct import Struct
 from .types import Array, Bytes, Int16, Int32, Schema, String
 
diff --git a/kafka/protocol/message.py b/kafka/protocol/message.py
index 795495d..f333800 100644
--- a/kafka/protocol/message.py
+++ b/kafka/protocol/message.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import io
 import time
 
diff --git a/kafka/protocol/metadata.py b/kafka/protocol/metadata.py
index 2711abb..7a04104 100644
--- a/kafka/protocol/metadata.py
+++ b/kafka/protocol/metadata.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .struct import Struct
 from .types import Array, Boolean, Int16, Int32, Schema, String
 
diff --git a/kafka/protocol/offset.py b/kafka/protocol/offset.py
index 57bf4ac..8d66063 100644
--- a/kafka/protocol/offset.py
+++ b/kafka/protocol/offset.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .struct import Struct
 from .types import Array, Int16, Int32, Int64, Schema, String
 
diff --git a/kafka/protocol/produce.py b/kafka/protocol/produce.py
index 560f92f..c1a519e 100644
--- a/kafka/protocol/produce.py
+++ b/kafka/protocol/produce.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .message import MessageSet
 from .struct import Struct
 from .types import Int16, Int32, Int64, String, Array, Schema
diff --git a/kafka/protocol/struct.py b/kafka/protocol/struct.py
index ca1013e..602cfb8 100644
--- a/kafka/protocol/struct.py
+++ b/kafka/protocol/struct.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 #from collections import namedtuple
 from io import BytesIO
 
diff --git a/kafka/structs.py b/kafka/structs.py
index 3188516..7d1d96a 100644
--- a/kafka/structs.py
+++ b/kafka/structs.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from collections import namedtuple
 
 
diff --git a/kafka/util.py b/kafka/util.py
index 349395c..bc01154 100644
--- a/kafka/util.py
+++ b/kafka/util.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import atexit
 import binascii
 import collections