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):