Removing the bit about offsets

1 files changed, 0 insertions, 5 deletions

diff --git a/kafka/consumer.py b/kafka/consumer.py
index 7f6a6f0..d09803a 100644
--- a/kafka/consumer.py
+++ b/kafka/consumer.py
@@ -219,11 +219,6 @@ class SimpleConsumer(object):
         start a new batch unless we've reached the end of ths partition.
         """
 
-        # Unless it is the first message in the queue, we have to fetch
-        # the next one
-        if offset != 0:
-            offset += 1
-
         while True:
             req = FetchRequest(self.topic, partition, offset, 1024) # TODO configure fetch size
             (resp,) = self.client.send_fetch_request([req])