diff options
| author | le-linh <48096349+le-linh@users.noreply.github.com> | 2019-03-03 15:09:10 -0500 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2019-03-03 15:09:10 -0500 |
| commit | 940b1c5582294ecc29ad308afbcebd605f3ab009 (patch) | |
| tree | 91c391c5e82859f5efc4fb4c39651f18d4b474a7 | |
| parent | fd3eb91ce7ccf5c03bba62a4e7138407bd28f239 (diff) | |
| download | kafka-python-940b1c5582294ecc29ad308afbcebd605f3ab009.tar.gz | |
Make NotEnoughReplicasError/NotEnoughReplicasAfterAppendError retriable (#1722)
| -rw-r--r-- | kafka/errors.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/kafka/errors.py b/kafka/errors.py index 118e430..f13f978 100644 --- a/kafka/errors.py +++ b/kafka/errors.py @@ -268,6 +268,7 @@ class NotEnoughReplicasError(BrokerResponseError): description = ('Returned from a produce request when the number of in-sync' ' replicas is lower than the configured minimum and' ' requiredAcks is -1.') + retriable = True class NotEnoughReplicasAfterAppendError(BrokerResponseError): @@ -276,6 +277,7 @@ class NotEnoughReplicasAfterAppendError(BrokerResponseError): description = ('Returned from a produce request when the message was' ' written to the log, but with fewer in-sync replicas than' ' required.') + retriable = True class InvalidRequiredAcksError(BrokerResponseError): |