Remove unused import

1 files 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):