openstack/monasca-common
Code Issues Proposed changes

Merge "Fix Kafka consumer commit"

Browse Source
This commit is contained in:
Jenkins 2016-02-04 21:47:32 +00:00 committed by Gerrit Code Review
commit 7089185f4d
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
monasca_common/kafka/consumer.py
View File

@ -220,4 +220,4 @@ class KafkaConsumer(object):
def commit(self):
self._last_commit = datetime.datetime.now()
self._consumer.commit()
self._consumer.commit(partitions=self._partitions)