From 88559a54e3d1f8eff7c32256b96a5ef502938fb3 Mon Sep 17 00:00:00 2001 From: Jim Lim Date: Wed, 2 Oct 2013 13:34:57 -0700 Subject: [PATCH] actually load metadata --- kafka/producer.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka/producer.py b/kafka/producer.py index 3e1fd3386..f7962da8a 100644 --- 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):