actually load metadata

dpkp · Oct 2, 2013 · 88559a5 · 88559a5
1 parent 8fcbe0c
commit 88559a5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafka/producer.py b/kafka/producer.py
@@ -113,7 +113,7 @@ def _send_upstream(self, queue):
                 self.client.send_produce_request(reqs, acks=self.req_acks,
                                                  timeout=self.ack_timeout)
             except Exception as exp:
-                self.client._load_metadata_for_topics
+                self.client._load_metadata_for_topics(self.topic)
                 log.error("Error sending message", exc_info=sys.exc_info())
 
     def send_messages(self, partition, *msg):