diff options
Diffstat (limited to 'kafka/cluster.py')
| -rw-r--r-- | kafka/cluster.py | 4 |
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): |