UnknownLeaderEpochError => invalid metadata

dpkp · dpkp · commit fb61535ecce3 · 2025-03-05T09:48:10.000-08:00
diff --git a/kafka/errors.py b/kafka/errors.py
@@ -664,6 +664,7 @@ class UnknownLeaderEpochError(BrokerResponseError):
     message = 'UNKNOWN_LEADER_EPOCH'
     description = 'The leader epoch in the request is newer than the epoch on the broker.'
     retriable = True
+    invalid_metadata = True
 
 
 class UnsupportedCompressionTypeError(BrokerResponseError):
