diff options
| -rw-r--r-- | kafka/client_async.py | 2 |
1 files changed, 1 insertions, 1 deletions
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: |