summaryrefslogtreecommitdiff
path: root/kafka/cluster.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/cluster.py
parentc0df771cf51bc27f2dd5d5af333666f4074e68c8 (diff)
downloadkafka-python-9ae0e590b5ea93a9c07d71b55b593e0fcc973bc6.tar.gz
use absolute imports everywhere (#1362)
Diffstat (limited to 'kafka/cluster.py')
-rw-r--r--kafka/cluster.py6
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__)