diff --git a/monasca_notification/processors/kafka_consumer.py b/monasca_notification/processors/kafka_consumer.py
index 7c51c6f..3589af0 100644
--- a/monasca_notification/processors/kafka_consumer.py
+++ b/monasca_notification/processors/kafka_consumer.py
@@ -49,7 +49,8 @@ class KafkaConsumer(BaseProcessor):
                                                        group,
                                                        self._kafka_topic,
                                                        auto_commit=False,
-                                                       iter_timeout=5)
+                                                       iter_timeout=5,
+                                                       max_buffer_size=None)
 
         self._consumer.provide_partition_info()  # Without this the partition is not provided in the response
         self._consumer.fetch_last_known_offsets()