diff options
| -rw-r--r-- | kafka/consumer.py | 5 |
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]) |