From 945fc048a8cc61e1a9390bd7a7fed371d2e23277 Mon Sep 17 00:00:00 2001
From: reAsOn2010 <the.reason.sake@gmail.com>
Date: Tue, 9 Jun 2015 04:20:16 +0800
Subject: try to fix uncaught FailedPayloadsError

---
 kafka/common.py | 2 ++
 1 file changed, 2 insertions(+)

(limited to 'kafka/common.py')

diff --git a/kafka/common.py b/kafka/common.py
index 2fdf7d2..66987ff 100644
--- a/kafka/common.py
+++ b/kafka/common.py
@@ -226,6 +226,8 @@ kafka_errors = dict([(x.errno, x) for x in _iter_broker_errors()])
 
 
 def check_error(response):
+    if isinstance(response, Exception):
+        raise response
     if response.error:
         error_class = kafka_errors.get(response.error, UnknownError)
         raise error_class(response)
-- 
cgit v1.2.1