diff options
| author | Mark Roberts <wizzat@gmail.com> | 2014-04-24 00:25:35 -0700 |
|---|---|---|
| committer | Mark Roberts <wizzat@gmail.com> | 2014-04-24 00:25:35 -0700 |
| commit | 0e50f33ec678f6d656d488ce8a4537f95bba003e (patch) | |
| tree | c828176727a8685ad79a4453581495d0aceb2ee4 /kafka/consumer.py | |
| parent | 583d3ae22bf6fc373c03e50c7e4eb26eaa50db4b (diff) | |
| download | kafka-python-0e50f33ec678f6d656d488ce8a4537f95bba003e.tar.gz | |
Fix last remaining test by making autocommit more intuitive
Diffstat (limited to 'kafka/consumer.py')
| -rw-r--r-- | kafka/consumer.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/consumer.py b/kafka/consumer.py index d855874..3f8d8c2 100644 --- a/kafka/consumer.py +++ b/kafka/consumer.py @@ -164,7 +164,7 @@ class Consumer(object): if not self.auto_commit or self.auto_commit_every_n is None: return - if self.count_since_commit > self.auto_commit_every_n: + if self.count_since_commit >= self.auto_commit_every_n: self.commit() def stop(self): |