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/cluster.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'kafka/cluster.py') diff --git a/kafka/cluster.py b/kafka/cluster.py index 863b0c2..69cc02e 100644 --- a/kafka/cluster.py +++ b/kafka/cluster.py @@ -32,6 +32,7 @@ class ClusterMetadata(object): self._need_update = False self._future = None self._listeners = set() + self.need_all_topic_metadata = False self.config = copy.copy(self.DEFAULT_CONFIG) for key in self.config: @@ -86,11 +87,12 @@ class ClusterMetadata(object): return max(ttl, next_retry, 0) def request_update(self): - """ - Flags metadata for update, return Future() + """Flags metadata for update, return Future() Actual update must be handled separately. This method will only change the reported ttl() + + Returns: Future (value will be this cluster object after update) """ self._need_update = True if not self._future or self._future.is_done: -- cgit v1.2.1