diff options
| author | Enrico Canzonieri <ecanzonieri@gmail.com> | 2015-01-26 16:24:20 -0800 |
|---|---|---|
| committer | Enrico Canzonieri <enrico@yelp.com> | 2015-01-26 16:24:20 -0800 |
| commit | 37d0b7f9dbac6c5165e6ea171a97be19c53c27f5 (patch) | |
| tree | 7f77ed1454077ce196ae1f327ca436a9f373a786 /kafka/consumer/simple.py | |
| parent | 9ab8415ed75b08c5de9f823708027bb4f10a0643 (diff) | |
| download | kafka-python-37d0b7f9dbac6c5165e6ea171a97be19c53c27f5.tar.gz | |
Retry failed partitions and add integration tests
Diffstat (limited to 'kafka/consumer/simple.py')
| -rw-r--r-- | kafka/consumer/simple.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/kafka/consumer/simple.py b/kafka/consumer/simple.py index 2ec99f2..4c835fe 100644 --- a/kafka/consumer/simple.py +++ b/kafka/consumer/simple.py @@ -348,6 +348,8 @@ class SimpleConsumer(Consumer): "Resetting partition offset...", resp.topic, resp.partition) self.reset_partition_offset(resp.partition) + # Retry this partition + retry_partitions[resp.partition] = partitions[resp.partition] continue partition = resp.partition |