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/errors.py | 4 ++++ 1 file changed, 4 insertions(+) (limited to 'kafka/errors.py') diff --git a/kafka/errors.py b/kafka/errors.py index f4c8740..93a9f40 100644 --- a/kafka/errors.py +++ b/kafka/errors.py @@ -54,6 +54,10 @@ class StaleMetadata(KafkaError): invalid_metadata = True +class MetadataEmptyBrokerList(KafkaError): + retriable = True + + class UnrecognizedBrokerVersion(KafkaError): pass -- cgit v1.2.1