diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-11-14 11:01:34 -0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2016-11-14 11:01:34 -0800 |
| commit | 8ac79fbe3dd1b28d052551a5fa3e6acfdc1ba457 (patch) | |
| tree | bc430da90685195db6532311f37781ac734479e5 /kafka/client_async.py | |
| parent | 77591afa789a4752f4d385228bea980f448f6a08 (diff) | |
| parent | cd74c1fe4053385151175b5100cb0a0d43bc31f6 (diff) | |
| download | kafka-python-8ac79fbe3dd1b28d052551a5fa3e6acfdc1ba457.tar.gz | |
Fix typos (#874)
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: |