summaryrefslogtreecommitdiff
path: root/kafka/coordinator/consumer.py
diff options
context:
space:
mode:
authorKevin Tindall <kevinkjt2000@users.noreply.github.com>2018-02-06 14:10:45 -0600
committerDana Powers <dana.powers@gmail.com>2018-02-06 12:10:45 -0800
commit9ae0e590b5ea93a9c07d71b55b593e0fcc973bc6 (patch)
tree7baee93ef095c3694a9ddbc50809b2a681ef56f8 /kafka/coordinator/consumer.py
parentc0df771cf51bc27f2dd5d5af333666f4074e68c8 (diff)
downloadkafka-python-9ae0e590b5ea93a9c07d71b55b593e0fcc973bc6.tar.gz
use absolute imports everywhere (#1362)
Diffstat (limited to 'kafka/coordinator/consumer.py')
-rw-r--r--kafka/coordinator/consumer.py22
1 files changed, 11 insertions, 11 deletions
diff --git a/kafka/coordinator/consumer.py b/kafka/coordinator/consumer.py
index 9438a7e..7a22c61 100644
--- a/kafka/coordinator/consumer.py
+++ b/kafka/coordinator/consumer.py
@@ -7,17 +7,17 @@ import time
from kafka.vendor import six
-from .base import BaseCoordinator, Generation
-from .assignors.range import RangePartitionAssignor
-from .assignors.roundrobin import RoundRobinPartitionAssignor
-from .protocol import ConsumerProtocol
-from .. import errors as Errors
-from ..future import Future
-from ..metrics import AnonMeasurable
-from ..metrics.stats import Avg, Count, Max, Rate
-from ..protocol.commit import OffsetCommitRequest, OffsetFetchRequest
-from ..structs import OffsetAndMetadata, TopicPartition
-from ..util import WeakMethod
+from kafka.coordinator.base import BaseCoordinator, Generation
+from kafka.coordinator.assignors.range import RangePartitionAssignor
+from kafka.coordinator.assignors.roundrobin import RoundRobinPartitionAssignor
+from kafka.coordinator.protocol import ConsumerProtocol
+from kafka import errors as Errors
+from kafka.future import Future
+from kafka.metrics import AnonMeasurable
+from kafka.metrics.stats import Avg, Count, Max, Rate
+from kafka.protocol.commit import OffsetCommitRequest, OffsetFetchRequest
+from kafka.structs import OffsetAndMetadata, TopicPartition
+from kafka.util import WeakMethod
log = logging.getLogger(__name__)