summaryrefslogtreecommitdiff
path: root/kafka/consumer/simple.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2015-06-08 18:19:56 -0700
committerDana Powers <dana.powers@gmail.com>2015-06-08 18:19:56 -0700
commit00c6b8635bca62e4facca105d33fdd250a2d5eb4 (patch)
tree94902a62beb5aff1a71a6dba7da7d96a09d71bca /kafka/consumer/simple.py
parentf1dc01e63bf174558d791b211b545428c984ae2b (diff)
parentb235ce89733e17997ad7192e10064d47da9ccfb4 (diff)
downloadkafka-python-00c6b8635bca62e4facca105d33fdd250a2d5eb4.tar.gz
Merge pull request #393 from dpkp/simple_consumer_leader_change
Simple consumer leader change
Diffstat (limited to 'kafka/consumer/simple.py')
-rw-r--r--kafka/consumer/simple.py5
1 files changed, 4 insertions, 1 deletions
diff --git a/kafka/consumer/simple.py b/kafka/consumer/simple.py
index 88eeada..384fa8e 100644
--- a/kafka/consumer/simple.py
+++ b/kafka/consumer/simple.py
@@ -344,9 +344,12 @@ class SimpleConsumer(Consumer):
try:
check_error(resp)
- except (UnknownTopicOrPartitionError, NotLeaderForPartitionError):
+ except UnknownTopicOrPartitionError:
self.client.reset_topic_metadata(resp.topic)
raise
+ except NotLeaderForPartitionError:
+ self.client.reset_topic_metadata(resp.topic)
+ continue
except OffsetOutOfRangeError:
log.warning("OffsetOutOfRangeError for %s - %d. "
"Resetting partition offset...",