From 6eecabfe85c75d5c33706168afedef0309775355 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@rd.io>
Date: Sun, 24 Jan 2016 12:46:05 -0800
Subject: Write bytes to wake_fd

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

diff --git a/kafka/client_async.py b/kafka/client_async.py
index 0e2636e..bb48cba 100644
--- a/kafka/client_async.py
+++ b/kafka/client_async.py
@@ -616,7 +616,7 @@ class KafkaClient(object):
             continue
 
     def wakeup(self):
-        os.write(self._wake_w, 'x')
+        os.write(self._wake_w, b'x')
 
     def _clear_wake_fd(self):
         while True:
-- 
cgit v1.2.1