From ba466a388f84b3d8878fc202a6d8644f082fc2dd Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Fri, 3 Mar 2017 12:20:37 -0800
Subject: When closing a broker connection without error, fail
 in-flight-requests with Cancelled

---
 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 ae3c55d..76a4177 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -510,7 +510,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