diff --git a/kafka/consumer.py b/kafka/consumer.py
index 28b53ec92..8ac28daf4 100644
--- a/kafka/consumer.py
+++ b/kafka/consumer.py
@@ -305,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):