Merge pull request #350 from ecanzonieri/enable_commit_on_seek

Enable commit on seek

kafka/consumer/simple.py

@@ -214,8 +214,8 @@ class SimpleConsumer(Consumer):
 
         # 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()