From 940b1c5582294ecc29ad308afbcebd605f3ab009 Mon Sep 17 00:00:00 2001
From: le-linh <48096349+le-linh@users.noreply.github.com>
Date: Sun, 3 Mar 2019 15:09:10 -0500
Subject: Make NotEnoughReplicasError/NotEnoughReplicasAfterAppendError
 retriable (#1722)

---
 kafka/errors.py | 2 ++
 1 file changed, 2 insertions(+)

(limited to 'kafka/errors.py')

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):
-- 
cgit v1.2.1