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 | |
| parent | c0df771cf51bc27f2dd5d5af333666f4074e68c8 (diff) | |
| download | kafka-python-9ae0e590b5ea93a9c07d71b55b593e0fcc973bc6.tar.gz | |
use absolute imports everywhere (#1362)
Diffstat (limited to 'kafka/coordinator')
| -rw-r--r-- | kafka/coordinator/assignors/range.py | 4 | ||||
| -rw-r--r-- | kafka/coordinator/assignors/roundrobin.py | 6 | ||||
| -rw-r--r-- | kafka/coordinator/base.py | 14 | ||||
| -rw-r--r-- | kafka/coordinator/consumer.py | 22 |
4 files changed, 23 insertions, 23 deletions
diff --git a/kafka/coordinator/assignors/range.py b/kafka/coordinator/assignors/range.py index cbf411e..c232d9e 100644 --- a/kafka/coordinator/assignors/range.py +++ b/kafka/coordinator/assignors/range.py @@ -5,8 +5,8 @@ import logging from kafka.vendor import six -from .abstract import AbstractPartitionAssignor -from ..protocol import ConsumerProtocolMemberMetadata, ConsumerProtocolMemberAssignment +from kafka.coordinator.assignors.abstract import AbstractPartitionAssignor +from kafka.coordinator.protocol import ConsumerProtocolMemberMetadata, ConsumerProtocolMemberAssignment log = logging.getLogger(__name__) diff --git a/kafka/coordinator/assignors/roundrobin.py b/kafka/coordinator/assignors/roundrobin.py index c241685..a831033 100644 --- a/kafka/coordinator/assignors/roundrobin.py +++ b/kafka/coordinator/assignors/roundrobin.py @@ -6,9 +6,9 @@ import logging from kafka.vendor import six -from .abstract import AbstractPartitionAssignor -from ...common import TopicPartition -from ..protocol import ConsumerProtocolMemberMetadata, ConsumerProtocolMemberAssignment +from kafka.coordinator.assignors.abstract import AbstractPartitionAssignor +from kafka.common import TopicPartition +from kafka.coordinator.protocol import ConsumerProtocolMemberMetadata, ConsumerProtocolMemberAssignment log = logging.getLogger(__name__) diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py index 820fc1f..57da971 100644 --- a/kafka/coordinator/base.py +++ b/kafka/coordinator/base.py @@ -10,13 +10,13 @@ import weakref from kafka.vendor import six -from .heartbeat import Heartbeat -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 GroupCoordinatorRequest, OffsetCommitRequest -from ..protocol.group import (HeartbeatRequest, JoinGroupRequest, +from kafka.coordinator.heartbeat import Heartbeat +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 GroupCoordinatorRequest, OffsetCommitRequest +from kafka.protocol.group import (HeartbeatRequest, JoinGroupRequest, LeaveGroupRequest, SyncGroupRequest) log = logging.getLogger('kafka.coordinator') 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__) |