diff options
Diffstat (limited to 'kafka/client_async.py')
| -rw-r--r-- | kafka/client_async.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/client_async.py b/kafka/client_async.py index 0849c7b..03a2f00 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -362,7 +362,7 @@ class KafkaClient(object): return def is_disconnected(self, node_id): - """Check whether the node connection has been disconnected failed. + """Check whether the node connection has been disconnected or failed. A disconnected node has either been closed or has failed. Connection failures are usually transient and can be resumed in the next ready() @@ -497,7 +497,7 @@ class KafkaClient(object): else: task_future.success(result) - # If we got a future that is already done, dont block in _poll + # If we got a future that is already done, don't block in _poll if future and future.is_done: timeout = 0 else: |