diff options
| author | Dana Powers <dana.powers@gmail.com> | 2017-03-07 11:33:23 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2017-03-07 12:24:55 -0800 |
| commit | a4338169d4e87536ed2e81ce41d9276e2f3d73a9 (patch) | |
| tree | 3f1fe0314af2985268d1ad4e26d4a4b3375057b8 /kafka/client_async.py | |
| parent | 1810816b00770c9aaf0e3175fe3d73d3ed19f81d (diff) | |
| download | kafka-python-a4338169d4e87536ed2e81ce41d9276e2f3d73a9.tar.gz | |
Add ClusterMetadata documentation
Diffstat (limited to 'kafka/client_async.py')
| -rw-r--r-- | kafka/client_async.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/kafka/client_async.py b/kafka/client_async.py index 9e30e09..5824e7a 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -48,6 +48,10 @@ class KafkaClient(object): This class is not thread-safe! + Attributes: + cluster (:any:`ClusterMetadata`): Local cache of cluster metadata, retrived + via MetadataRequests during :meth:`.poll`. + Keyword Arguments: bootstrap_servers: 'host[:port]' string (or list of 'host[:port]' strings) that the consumer should contact to bootstrap initial |