diff options
author | Kevin Tindall <kevinkjt2000@users.noreply.github.com> | 2018-02-06 14:10:45 -0600 |
---|---|---|
committer | Dana Powers <dana.powers@gmail.com> | 2018-02-06 12:10:45 -0800 |
commit | 9ae0e590b5ea93a9c07d71b55b593e0fcc973bc6 (patch) | |
tree | 7baee93ef095c3694a9ddbc50809b2a681ef56f8 /kafka/coordinator/consumer.py | |
parent | c0df771cf51bc27f2dd5d5af333666f4074e68c8 (diff) | |
download | kafka-python-9ae0e590b5ea93a9c07d71b55b593e0fcc973bc6.tar.gz |
use absolute imports everywhere (#1362)
Diffstat (limited to 'kafka/coordinator/consumer.py')
-rw-r--r-- | kafka/coordinator/consumer.py | 22 |
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__) |