diff --git a/kafka/consumer/simple.py b/kafka/consumer/simple.py index 3d250eaf2..b50de61f8 100644 --- a/kafka/consumer/simple.py +++ b/kafka/consumer/simple.py @@ -214,8 +214,8 @@ def seek(self, offset, whence): # Reset queue and fetch offsets since they are invalid self.fetch_offsets = self.offsets.copy() + self.count_since_commit += 1 if self.auto_commit: - self.count_since_commit += 1 self.commit() self.queue = Queue()