From f5acccf07b03f30f5f1b6f48c5f0166de8ab3d26 Mon Sep 17 00:00:00 2001 From: Jeff Widman Date: Wed, 22 May 2019 18:06:32 -0700 Subject: Remove unused import --- kafka/cluster.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/kafka/cluster.py b/kafka/cluster.py index 28b71c9..4169549 100644 --- a/kafka/cluster.py +++ b/kafka/cluster.py @@ -9,7 +9,7 @@ import time from kafka.vendor import six from kafka import errors as Errors -from kafka.conn import collect_hosts, dns_lookup +from kafka.conn import collect_hosts from kafka.future import Future from kafka.structs import BrokerMetadata, PartitionMetadata, TopicPartition @@ -189,7 +189,7 @@ class ClusterMetadata(object): with self._lock: self._need_update = True if not self._future or self._future.is_done: - self._future = Future() + self._future = Future() return self._future def topics(self, exclude_internal_topics=True): -- cgit v1.2.1