Init responses before we use it.

1 files changed, 1 insertions, 1 deletions

diff --git a/kafka/client.py b/kafka/client.py
index 87b51c3..9846acf 100644
--- a/kafka/client.py
+++ b/kafka/client.py
@@ -161,6 +161,7 @@ class KafkaClient(object):
         brokers_for_payloads = []
         payloads_by_broker = collections.defaultdict(list)
 
+        responses = {}
         for payload in payloads:
             try:
                 leader = self._get_leader_for_partition(payload.topic,
@@ -175,7 +176,6 @@ class KafkaClient(object):
 
         # For each broker, send the list of request payloads
         # and collect the responses and errors
-        responses = {}
         broker_failures = []
         for broker, payloads in payloads_by_broker.items():
             requestId = self._next_id()