summaryrefslogtreecommitdiff
path: root/kafka/consumer.py
diff options
context:
space:
mode:
authorMark Roberts <wizzat@gmail.com>2014-04-08 23:45:53 -0700
committerMark Roberts <wizzat@gmail.com>2014-04-08 23:45:53 -0700
commita3c781fda5223b443ad6179b68faaf52792b158c (patch)
tree6fd40ed889a8e0a1ef3dcd7dc54fc6711364f2b6 /kafka/consumer.py
parent3bde6d6b1cc2a826ab2a8e43b2e0799a75e3ae78 (diff)
parent13d0d445da2060b1b94c742e9d69cb1db22fc775 (diff)
downloadkafka-python-a3c781fda5223b443ad6179b68faaf52792b158c.tar.gz
Merge branch 'master' into add_tests
Diffstat (limited to 'kafka/consumer.py')
-rw-r--r--kafka/consumer.py4
1 files changed, 4 insertions, 0 deletions
diff --git a/kafka/consumer.py b/kafka/consumer.py
index 28b53ec..8ac28da 100644
--- a/kafka/consumer.py
+++ b/kafka/consumer.py
@@ -305,6 +305,10 @@ class SimpleConsumer(Consumer):
# 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):