diff options
Diffstat (limited to 'kafka/cluster.py')
| -rw-r--r-- | kafka/cluster.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/kafka/cluster.py b/kafka/cluster.py index 1ab4218..5be3c2f 100644 --- a/kafka/cluster.py +++ b/kafka/cluster.py @@ -8,9 +8,9 @@ import time from kafka.vendor import six -from . import errors as Errors -from .future import Future -from .structs import BrokerMetadata, PartitionMetadata, TopicPartition +from kafka import errors as Errors +from kafka.future import Future +from kafka.structs import BrokerMetadata, PartitionMetadata, TopicPartition log = logging.getLogger(__name__) |