clean local metadata before requesting refresh in load_metadata_for_topics()

Dana Powers · Dana Powers · commit d5c9a11a574f · 2015-04-12T10:46:17.000-07:00
diff --git a/kafka/client.py b/kafka/client.py
@@ -311,6 +311,13 @@ def load_metadata_for_topics(self, *topics):
         (a single partition w/o a leader, for example)
         """
         topics = [kafka_bytestring(t) for t in topics]
+
+        if topics:
+            for topic in topics:
+                self.reset_topic_metadata(topic)
+        else:
+            self.reset_all_metadata()
+
         resp = self.send_metadata_request(topics)
 
         log.debug("Broker metadata: %s", resp.brokers)
@@ -323,8 +330,6 @@ def load_metadata_for_topics(self, *topics):
             topic = topic_metadata.topic
             partitions = topic_metadata.partitions
 
-            self.reset_topic_metadata(topic)
-
             # Errors expected for new topics
             try:
                 kafka.common.check_error(topic_metadata)
