Commit in seek if autocommit

Author: Mark Roberts

kafka/consumer.py

@@ -275,7 +275,6 @@ def seek(self, offset, whence):
                 2 is relative to the latest known offset (tail)
         """
 
-        self.count_since_commit += 1
         if whence == 1:  # relative to current position
             for partition, _offset in self.offsets.items():
                 self.offsets[partition] = _offset + offset
@@ -306,6 +305,10 @@ def seek(self, offset, whence):
 
         # Reset queue and fetch offsets since they are invalid
         self.fetch_offsets = self.offsets.copy()
+        if self.auto_commit:
+            self.count_since_commit += 1
+            self.commit()
+
         self.queue = Queue()
 
     def get_messages(self, count=1, block=True, timeout=0.1):