From a4338169d4e87536ed2e81ce41d9276e2f3d73a9 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Tue, 7 Mar 2017 11:33:23 -0800 Subject: Add ClusterMetadata documentation --- kafka/client_async.py | 4 ++++ 1 file changed, 4 insertions(+) (limited to 'kafka/client_async.py') 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 -- cgit v1.2.1