From 2916bb865085ae2b883bc74dc4988b6b7723917d Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@rd.io>
Date: Sat, 5 Dec 2015 03:59:09 -0800
Subject: Revert broken send_produce_request try/except from PR 467
 (resps=None)

---
 kafka/client.py | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)

(limited to 'kafka/client.py')

diff --git a/kafka/client.py b/kafka/client.py
index b3dcf51..9018bb4 100644
--- a/kafka/client.py
+++ b/kafka/client.py
@@ -607,11 +607,7 @@ class KafkaClient(object):
         else:
             decoder = KafkaProtocol.decode_produce_response
 
-        try:
-            resps = self._send_broker_aware_request(payloads, encoder, decoder)
-        except Exception:
-            if fail_on_error:
-                raise
+        resps = self._send_broker_aware_request(payloads, encoder, decoder)
 
         return [resp if not callback else callback(resp) for resp in resps
                 if resp is not None and
-- 
cgit v1.2.1