From ee26c3f547f357d639b421b3e38a74e87e21f346 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sat, 26 May 2018 08:43:25 -0700 Subject: Ignore MetadataResponses with empty broker list (#1506) --- kafka/cluster.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'kafka/cluster.py') diff --git a/kafka/cluster.py b/kafka/cluster.py index 45f25ad..8078eb7 100644 --- a/kafka/cluster.py +++ b/kafka/cluster.py @@ -214,7 +214,8 @@ class ClusterMetadata(object): return self.failed_update(error) if not metadata.brokers: - log.warning("No broker metadata found in MetadataResponse") + log.warning("No broker metadata found in MetadataResponse -- ignoring.") + return self.failed_update(Errors.MetadataEmptyBrokerList(metadata)) _new_brokers = {} for broker in metadata.brokers: -- cgit v1.2.1