From d0f4abe05d02458ad8a4a19e75d1ec86fb67ab3e Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sat, 17 Dec 2016 10:37:28 -0800 Subject: Pass error to BrokerConnection.close() --- kafka/client_async.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'kafka/client_async.py') diff --git a/kafka/client_async.py b/kafka/client_async.py index bb96578..6179eba 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -557,7 +557,7 @@ class KafkaClient(object): log.warning('Protocol out of sync on %r, closing', conn) except socket.error: pass - conn.close() + conn.close(Errors.ConnectionError('Socket EVENT_READ without in-flight-requests')) continue # Accumulate as many responses as the connection has pending -- cgit v1.2.1