From 54a735bed082feecd68f15f63453e7f6ca58d547 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Mon, 25 Jan 2016 22:44:54 -0800 Subject: Add error 104 / Connection reset by peer to expected check_version errors --- kafka/client_async.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'kafka/client_async.py') diff --git a/kafka/client_async.py b/kafka/client_async.py index af414e2..04bdf36 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -579,7 +579,7 @@ class KafkaClient(object): # so we can send a test request and then follow immediately with a # vanilla MetadataRequest. If the server did not recognize the first # request, both will be failed with a ConnectionError that wraps - # socket.error (32 or 54) + # socket.error (32, 54, or 104) import socket from .protocol.admin import ListGroupsRequest from .protocol.commit import ( @@ -619,7 +619,7 @@ class KafkaClient(object): if six.PY2: assert isinstance(f.exception.args[0], socket.error) - assert f.exception.args[0].errno in (32, 54) + assert f.exception.args[0].errno in (32, 54, 104) else: assert isinstance(f.exception.args[0], ConnectionError) log.info("Broker is not v%s -- it did not recognize %s", -- cgit v1.2.1