diff options
| author | Dana Powers <dana.powers@rd.io> | 2016-01-24 12:46:05 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2016-01-24 12:46:05 -0800 |
| commit | 6eecabfe85c75d5c33706168afedef0309775355 (patch) | |
| tree | b39386c6e5892482ee4b5d3e1e4608f6b4090cd5 | |
| parent | 80c3a76aa65ad3f704565038fef7938dae39345f (diff) | |
| download | kafka-python-6eecabfe85c75d5c33706168afedef0309775355.tar.gz | |
Write bytes to wake_fd
| -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: |