From 6527c262feb21069a76b0a826f1f832ec5802fc1 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Mon, 13 Apr 2026 10:39:11 -0700 Subject: [PATCH] Fixup kafka.cluster docstrings --- kafka/cluster.py | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/kafka/cluster.py b/kafka/cluster.py index 42fd7a168..ba70e1d98 100644 --- a/kafka/cluster.py +++ b/kafka/cluster.py @@ -131,11 +131,18 @@ def brokers(self): """Get all MetadataResponseBroker Returns: - set: {MetadataResponseBroker, ...} + list: [MetadataResponseBroker, ...] """ return list(self._brokers.values()) def bootstrap_brokers(self): + """Get bootstrap brokers only, extracted from the + bootstrap_servers config option. Node ids are synthesized + as 'bootstrap-0' etc. + + Returns: + list: [MetadataResponseBroker, ...] + """ return list(self._bootstrap_brokers.values()) def broker_metadata(self, broker_id):