diff --git a/monasca_common/kafka/consumer.py b/monasca_common/kafka/consumer.py
index 40ec3924..dfedda48 100644
--- a/monasca_common/kafka/consumer.py
+++ b/monasca_common/kafka/consumer.py
@@ -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)