From 9868ab04f70d684d1fcfd34a04a8f277d0fa37f6 Mon Sep 17 00:00:00 2001
From: Taras Voinarovskiy <voyn1991@gmail.com>
Date: Sun, 30 Jul 2017 12:41:27 +0000
Subject: Make UnknownTopicOrPartitionError retriable error

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

(limited to 'kafka/errors.py')

diff --git a/kafka/errors.py b/kafka/errors.py
index 8fcaf59..35f9d94 100644
--- a/kafka/errors.py
+++ b/kafka/errors.py
@@ -109,6 +109,7 @@ class UnknownTopicOrPartitionError(BrokerResponseError):
     message = 'UNKNOWN_TOPIC_OR_PARTITION'
     description = ('This request is for a topic or partition that does not'
                    ' exist on this broker.')
+    retriable = True
     invalid_metadata = True
 
 
-- 
cgit v1.2.1