diff options
Diffstat (limited to 'kafka/coordinator/assignors/range.py')
| -rw-r--r-- | kafka/coordinator/assignors/range.py | 4 |
1 files changed, 2 insertions, 2 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__) |