Skip to content

Commit 940b1c5

Browse files
le-linhdpkp
authored andcommitted
Make NotEnoughReplicasError/NotEnoughReplicasAfterAppendError retriable (#1722)
1 parent fd3eb91 commit 940b1c5

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

kafka/errors.py

+2
Original file line numberDiff line numberDiff line change
@@ -268,6 +268,7 @@ class NotEnoughReplicasError(BrokerResponseError):
268268
description = ('Returned from a produce request when the number of in-sync'
269269
' replicas is lower than the configured minimum and'
270270
' requiredAcks is -1.')
271+
retriable = True
271272

272273

273274
class NotEnoughReplicasAfterAppendError(BrokerResponseError):
@@ -276,6 +277,7 @@ class NotEnoughReplicasAfterAppendError(BrokerResponseError):
276277
description = ('Returned from a produce request when the message was'
277278
' written to the log, but with fewer in-sync replicas than'
278279
' required.')
280+
retriable = True
279281

280282

281283
class InvalidRequiredAcksError(BrokerResponseError):

0 commit comments

Comments
 (0)