diff options
Diffstat (limited to 'kafka/client_async.py')
| -rw-r--r-- | kafka/client_async.py | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/kafka/client_async.py b/kafka/client_async.py index 04bdf36..029a419 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -514,8 +514,12 @@ class KafkaClient(object): node_id = self.least_loaded_node() + topics = list(self._topics) + if self.cluster.need_all_topic_metadata: + topics = [] + if self._can_send_request(node_id): - request = MetadataRequest(list(self._topics)) + request = MetadataRequest(topics) log.debug("Sending metadata request %s to node %s", request, node_id) future = self.send(node_id, request) future.add_callback(self.cluster.update_metadata) |