Always absolute_import

kafka/__init__.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 __title__ = 'kafka'
 from .version import __version__
 __author__ = 'Dana Powers'

kafka/client.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import collections
 import copy
 import functools

kafka/common.py

@@ -1,2 +1,4 @@
+from __future__ import absolute_import
+
 from kafka.structs import *
 from kafka.errors import *

kafka/conn.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import collections
 import copy
 import errno

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

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

kafka/coordinator/assignors/abstract.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import abc
 import logging
 

kafka/coordinator/assignors/range.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import collections
 import logging
 

kafka/coordinator/assignors/roundrobin.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import collections
 import itertools
 import logging

kafka/coordinator/heartbeat.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import copy
 import time
 

kafka/errors.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import inspect
 import sys
 

kafka/future.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import functools
 import logging
 

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

kafka/metrics/compound_stat.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import abc
 
 from kafka.metrics.stat import AbstractStat

kafka/metrics/dict_reporter.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import logging
 import threading
 

kafka/metrics/kafka_metric.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import time
 
 

kafka/metrics/measurable.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import abc
 
 

kafka/metrics/measurable_stat.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import abc
 
 from kafka.metrics.measurable import AbstractMeasurable

kafka/metrics/metric_config.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import sys
 
 

kafka/metrics/metric_name.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import copy
 
 

kafka/metrics/metrics.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import logging
 import sys
 import time

kafka/metrics/metrics_reporter.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import abc
 
 

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):

kafka/metrics/stat.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import abc
 
 

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

kafka/metrics/stats/avg.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from kafka.metrics.stats.sampled_stat import AbstractSampledStat
 
 

kafka/metrics/stats/count.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from kafka.metrics.stats.sampled_stat import AbstractSampledStat
 
 

kafka/metrics/stats/histogram.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import math
 
 

kafka/metrics/stats/max_stat.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from kafka.metrics.stats.sampled_stat import AbstractSampledStat
 
 

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

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

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

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
 

kafka/metrics/stats/sampled_stat.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import abc
 
 from kafka.metrics.measurable_stat import AbstractMeasurableStat

kafka/metrics/stats/sensor.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import threading
 import time
 

kafka/metrics/stats/total.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from kafka.metrics.measurable_stat import AbstractMeasurableStat
 
 

kafka/partitioner/__init__.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .roundrobin import RoundRobinPartitioner
 from .hashed import HashedPartitioner, Murmur2Partitioner, LegacyPartitioner
 

kafka/partitioner/base.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 
 class Partitioner(object):
     """

kafka/partitioner/default.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import random
 
 from .hashed import murmur2

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

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

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,

kafka/protocol/abstract.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import abc
 
 

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
 

kafka/protocol/api.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .struct import Struct
 from .types import Int16, Int32, String, Schema
 

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
 

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

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
 

kafka/protocol/message.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import io
 import time
 

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
 

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
 

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

kafka/protocol/struct.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 #from collections import namedtuple
 from io import BytesIO
 

kafka/structs.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from collections import namedtuple
 
 

kafka/util.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import atexit
 import binascii
 import collections

test/__init__.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import sys
 
 if sys.version_info < (2, 7):

test/conftest.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import os
 
 import pytest

test/fixtures.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import atexit
 import logging
 import os

test/service.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import logging
 import os
 import re