summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorTaras Voinarovskiy <voyn1991@gmail.com>2017-07-30 12:41:27 +0000
committerTaras Voinarovskiy <voyn1991@gmail.com>2017-07-30 12:41:27 +0000
commit9868ab04f70d684d1fcfd34a04a8f277d0fa37f6 (patch)
tree91400aab071cc6d6b3a71423663c300cb5d1f5d3
parentca02bb17bf0d7913736596594874c0274f1b7653 (diff)
downloadkafka-python-9868ab04f70d684d1fcfd34a04a8f277d0fa37f6.tar.gz
Make UnknownTopicOrPartitionError retriable errorissue1155
-rw-r--r--kafka/errors.py1
1 files changed, 1 insertions, 0 deletions
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