diff options
author | Dana Powers <dana.powers@rd.io> | 2016-01-07 17:03:08 -0800 |
---|---|---|
committer | Dana Powers <dana.powers@rd.io> | 2016-01-07 17:03:08 -0800 |
commit | e080c6b0cdb54563e3c5ad595d582de26561d9f0 (patch) | |
tree | 0a3e686336667bb98c4be4bb324292fa29767a67 /kafka/client.py | |
parent | c8deb0c276d57209006eebdd910017846860a38d (diff) | |
download | kafka-python-e080c6b0cdb54563e3c5ad595d582de26561d9f0.tar.gz |
Docstring updates
Diffstat (limited to 'kafka/client.py')
-rw-r--r-- | kafka/client.py | 39 |
1 files changed, 18 insertions, 21 deletions
diff --git a/kafka/client.py b/kafka/client.py index 2f070cd..14e71bb 100644 --- a/kafka/client.py +++ b/kafka/client.py @@ -455,31 +455,28 @@ class KafkaClient(object): time.sleep(.5) def load_metadata_for_topics(self, *topics): - """ - Fetch broker and topic-partition metadata from the server, - and update internal data: - broker list, topic/partition list, and topic/parition -> broker map + """Fetch broker and topic-partition metadata from the server. + + Updates internal data: broker list, topic/partition list, and + topic/parition -> broker map. This method should be called after + receiving any error. - This method should be called after receiving any error + Note: Exceptions *will not* be raised in a full refresh (i.e. no topic + list). In this case, error codes will be logged as errors. + Partition-level errors will also not be raised here (a single partition + w/o a leader, for example). Arguments: *topics (optional): If a list of topics is provided, - the metadata refresh will be limited to the specified topics only. - - Exceptions: - ---------- - If the broker is configured to not auto-create topics, - expect UnknownTopicOrPartitionError for topics that don't exist - - If the broker is configured to auto-create topics, - expect LeaderNotAvailableError for new topics - until partitions have been initialized. - - Exceptions *will not* be raised in a full refresh (i.e. no topic list) - In this case, error codes will be logged as errors - - Partition-level errors will also not be raised here - (a single partition w/o a leader, for example) + the metadata refresh will be limited to the specified topics + only. + + Raises: + UnknownTopicOrPartitionError: Raised for topics that do not exist, + unless the broker is configured to auto-create topics. + LeaderNotAvailableError: Raised for topics that do not exist yet, + when the broker is configured to auto-create topics. Retry + after a short backoff (topics/partitions are initializing). """ if topics: self.reset_topic_metadata(*topics) |