From 1f4feee0188768a54eb348ca7d9f374cc5d1bd51 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Mon, 1 Apr 2019 20:14:44 -0700
Subject: [PATCH] Fix possible AttribueError during conn._close_socket

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

diff --git a/kafka/conn.py b/kafka/conn.py
index 33950dbbf..c886a7e1f 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -769,7 +769,7 @@ def _update_reconnect_backoff(self):
             log.debug('%s: reconnect backoff %s after %s failures', self, self._reconnect_backoff, self._failures)
 
     def _close_socket(self):
-        if self._sock:
+        if hasattr(self, '_sock') and self._sock is not None:
             self._sock.close()
             self._sock = None