diff options
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 |