diff options
| -rw-r--r-- | kafka/conn.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index a1767ef..0e02382 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -165,8 +165,9 @@ class BrokerConnection(object): self._sock.setblocking(False) except (AssertionError, socket.error) as e: log.exception("Error sending %s to %s", request, self) - self.close(error=Errors.ConnectionError(e)) - return future.failure(e) + error = Errors.ConnectionError(e) + self.close(error=error) + return future.failure(error) log.debug('%s Request %d: %s', self, correlation_id, request) if expect_response: |