From dc8e6b8317c3029670fd3794c30453bd64fdafc7 Mon Sep 17 00:00:00 2001
From: Bugra Gedik <bgedik@unscrambl.com>
Date: Thu, 18 Jan 2018 13:36:35 -0800
Subject: [PATCH] Remove assertion with side effect

---
 kafka/client_async.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/kafka/client_async.py b/kafka/client_async.py
index 29cb8c0fc..2e78e3b3a 100644
--- a/kafka/client_async.py
+++ b/kafka/client_async.py
@@ -852,8 +852,8 @@ def check_version(self, node_id=None, timeout=2, strict=False):
     def wakeup(self):
         with self._wake_lock:
             try:
-                assert self._wake_w.send(b'x') == 1
-            except (AssertionError, socket.error):
+                self._wake_w.sendall(b'x')
+            except socket.error:
                 log.warning('Unable to send to wakeup socket!')
 
     def _clear_wake_fd(self):