Update kafka-src to latest 0.8

Fix a broken test (100k was too much to send in one batch)

1 files changed, 1 insertions, 1 deletions

diff --git a/kafka/client.py b/kafka/client.py
index 23b0a48..1c7fc93 100644
--- a/kafka/client.py
+++ b/kafka/client.py
@@ -116,7 +116,7 @@ class KafkaClient(object):
         for payload in payloads:
             payloads_by_broker[self._get_leader_for_partition(payload.topic, payload.partition)].append(payload)
             original_keys.append((payload.topic, payload.partition))
-        
+
         # Accumulate the responses in a dictionary
         acc = {}