From 61eb396bba268f892a657b2e4d7bd813aabc88ec Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Fri, 3 Mar 2017 17:51:48 -0800
Subject: When closing a broker connection without error, fail
 in-flight-requests with Cancelled (#1010)

---
 kafka/conn.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'kafka/conn.py')

diff --git a/kafka/conn.py b/kafka/conn.py
index 8f4fefe..ab86804 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -511,7 +511,7 @@ class BrokerConnection(object):
         self._rbuffer.seek(0)
         self._rbuffer.truncate()
         if error is None:
-            error = Errors.ConnectionError(str(self))
+            error = Errors.Cancelled(str(self))
         while self.in_flight_requests:
             ifr = self.in_flight_requests.popleft()
             ifr.future.failure(error)
-- 
cgit v1.2.1