Merge "Set node to run on label docker"

[osm/MON.git] / osm_mon / core / message_bus / consumer.py

diff --git a/osm_mon/core/message_bus/consumer.py b/osm_mon/core/message_bus/consumer.py
index 363b9fc..7936513 100644 (file)
--- a/osm_mon/core/message_bus/consumer.py
+++ b/osm_mon/core/message_bus/consumer.py
@@ -10,4 +10,5 @@ class Consumer(KafkaConsumer):
         super().__init__(bootstrap_servers=cfg.BROKER_URI,
                          key_deserializer=bytes.decode,
                          value_deserializer=bytes.decode,
+                         max_poll_interval_ms=900000,
                          group_id=group_id)