Implement KafkaConsumer.topics()

 - add ClusterMetadata.need_all_topic_metadata attribute
 - client requests metadata for all topics if attribute True

1 files changed, 4 insertions, 2 deletions

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: