diff options
| -rw-r--r-- | kafka/client_async.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/kafka/client_async.py b/kafka/client_async.py index 2eb86cf..ea2621e 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -133,8 +133,10 @@ class KafkaClient(object): self._selector.register(self._wake_r, selectors.EVENT_READ) def __del__(self): - self._wake_r.close() - self._wake_w.close() + if hasattr(self, '_wake_r'): + self._wake_r.close() + if hasattr(self, '_wake_w'): + self._wake_w.close() def _bootstrap(self, hosts): # Exponential backoff if bootstrap fails |