From d3d6ea939b85ca033293898e2c4c63eda2335aab Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sun, 31 Jan 2016 23:54:34 -0800 Subject: Implement KafkaConsumer.topics() - add ClusterMetadata.need_all_topic_metadata attribute - client requests metadata for all topics if attribute True --- kafka/client_async.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) (limited to 'kafka/client_async.py') 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) -- cgit v1.2.1