From 81d001bfa2b6936dbefd8515204c2d51a7f299f8 Mon Sep 17 00:00:00 2001 From: Omar Ghishan Date: Fri, 3 Jan 2014 15:18:32 -0800 Subject: [PATCH] Fix seek offset deltas We always store the offset of the next available message, so we shouldn't decrement the offset deltas when seeking by an extra 1 --- kafka/consumer.py | 6 ------ 1 file changed, 6 deletions(-) diff --git a/kafka/consumer.py b/kafka/consumer.py index ff08da4..8cf2760 100644 --- a/kafka/consumer.py +++ b/kafka/consumer.py @@ -280,12 +280,6 @@ 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