summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2016-08-02 21:36:00 -0700
committerDana Powers <dana.powers@gmail.com>2016-08-02 21:36:00 -0700
commitc693709aaf9e292c8614b9ab345d3322d4f71caa (patch)
tree74545ef0d8646c152dc55bc29454308cdd3b95e2
parentaed1a09401b5ebec4278fd2e393c1249a0efd562 (diff)
downloadkafka-python-c693709aaf9e292c8614b9ab345d3322d4f71caa.tar.gz
Always absolute_importabsolute_import
-rw-r--r--kafka/__init__.py2
-rw-r--r--kafka/client.py2
-rw-r--r--kafka/common.py2
-rw-r--r--kafka/conn.py2
-rw-r--r--kafka/consumer/__init__.py2
-rw-r--r--kafka/context.py2
-rw-r--r--kafka/coordinator/assignors/abstract.py2
-rw-r--r--kafka/coordinator/assignors/range.py2
-rw-r--r--kafka/coordinator/assignors/roundrobin.py2
-rw-r--r--kafka/coordinator/heartbeat.py2
-rw-r--r--kafka/errors.py2
-rw-r--r--kafka/future.py2
-rw-r--r--kafka/metrics/__init__.py2
-rw-r--r--kafka/metrics/compound_stat.py2
-rw-r--r--kafka/metrics/dict_reporter.py2
-rw-r--r--kafka/metrics/kafka_metric.py2
-rw-r--r--kafka/metrics/measurable.py2
-rw-r--r--kafka/metrics/measurable_stat.py2
-rw-r--r--kafka/metrics/metric_config.py2
-rw-r--r--kafka/metrics/metric_name.py2
-rw-r--r--kafka/metrics/metrics.py2
-rw-r--r--kafka/metrics/metrics_reporter.py2
-rw-r--r--kafka/metrics/quota.py3
-rw-r--r--kafka/metrics/stat.py2
-rw-r--r--kafka/metrics/stats/__init__.py2
-rw-r--r--kafka/metrics/stats/avg.py2
-rw-r--r--kafka/metrics/stats/count.py2
-rw-r--r--kafka/metrics/stats/histogram.py2
-rw-r--r--kafka/metrics/stats/max_stat.py2
-rw-r--r--kafka/metrics/stats/min_stat.py2
-rw-r--r--kafka/metrics/stats/percentile.py3
-rw-r--r--kafka/metrics/stats/percentiles.py2
-rw-r--r--kafka/metrics/stats/rate.py2
-rw-r--r--kafka/metrics/stats/sampled_stat.py2
-rw-r--r--kafka/metrics/stats/sensor.py2
-rw-r--r--kafka/metrics/stats/total.py2
-rw-r--r--kafka/partitioner/__init__.py2
-rw-r--r--kafka/partitioner/base.py2
-rw-r--r--kafka/partitioner/default.py2
-rw-r--r--kafka/partitioner/roundrobin.py3
-rw-r--r--kafka/producer/__init__.py2
-rw-r--r--kafka/protocol/__init__.py2
-rw-r--r--kafka/protocol/abstract.py2
-rw-r--r--kafka/protocol/admin.py2
-rw-r--r--kafka/protocol/api.py2
-rw-r--r--kafka/protocol/commit.py2
-rw-r--r--kafka/protocol/fetch.py2
-rw-r--r--kafka/protocol/group.py2
-rw-r--r--kafka/protocol/message.py2
-rw-r--r--kafka/protocol/metadata.py2
-rw-r--r--kafka/protocol/offset.py2
-rw-r--r--kafka/protocol/produce.py2
-rw-r--r--kafka/protocol/struct.py2
-rw-r--r--kafka/structs.py2
-rw-r--r--kafka/util.py2
-rw-r--r--test/__init__.py2
-rw-r--r--test/conftest.py2
-rw-r--r--test/fixtures.py2
-rw-r--r--test/service.py2
59 files changed, 121 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
diff --git a/test/__init__.py b/test/__init__.py
index 0eb2edc..3d2ba3d 100644
--- a/test/__init__.py
+++ b/test/__init__.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
import sys
if sys.version_info < (2, 7):
diff --git a/test/conftest.py b/test/conftest.py
index c2ef1dd..79ad074 100644
--- a/test/conftest.py
+++ b/test/conftest.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
import os
import pytest
diff --git a/test/fixtures.py b/test/fixtures.py
index b8d6fc3..637896d 100644
--- a/test/fixtures.py
+++ b/test/fixtures.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
import atexit
import logging
import os
diff --git a/test/service.py b/test/service.py
index 8895a10..47fb846 100644
--- a/test/service.py
+++ b/test/service.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
import logging
import os
import re