diff options
| -rw-r--r-- | kafka/consumer.py | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/kafka/consumer.py b/kafka/consumer.py index b87ed1c..67e1b10 100644 --- a/kafka/consumer.py +++ b/kafka/consumer.py @@ -259,6 +259,12 @@ class SimpleConsumer(Consumer): reqs.append(OffsetRequest(self.topic, partition, -2, 1)) elif whence == 2: reqs.append(OffsetRequest(self.topic, partition, -1, 1)) + + # The API returns back the next available offset + # For eg: if the current offset is 18, the API will return + # back 19. So, if we have to seek 5 points before, we will + # end up going back to 14, instead of 13. Adjust this + deltas[partition] -= 1 else: pass |