From 237c765bbeb21e70b19c8178c03b4cedc0a7ac13 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Mon, 17 Mar 2025 15:30:46 -0700 Subject: [PATCH] Fix Fetcher retriable error handling --- kafka/consumer/fetcher.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py index 7527a1f39..641a0f259 100644 --- a/kafka/consumer/fetcher.py +++ b/kafka/consumer/fetcher.py @@ -934,9 +934,9 @@ def _parse_fetched_data(self, completed_fetch): elif error_type is Errors.TopicAuthorizationFailedError: log.warning("Not authorized to read from topic %s.", tp.topic) raise Errors.TopicAuthorizationFailedError(set([tp.topic])) - elif error_type.is_retriable: + elif getattr(error_type, 'retriable', False): log.debug("Retriable error fetching partition %s: %s", tp, error_type()) - if error_type.invalid_metadata: + if getattr(error_type, 'invalid_metadata', False): self._client.cluster.request_update() else: raise error_type('Unexpected error while fetching data')