X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_mon%2Fcore%2Fmessage_bus%2Fconsumer.py;h=c0a9dd0ca59bdd0b316333771671e7e52132d67f;hb=0e34244e420bd68e6acb0cf6bb4383fedb662070;hp=1ccf936e1fd271cf3bb7df57f1bfef00b5ff8f98;hpb=987f8f62bf405ac78a4a1ea3f6e634c686119e05;p=osm%2FMON.git

diff --git a/osm_mon/core/message_bus/consumer.py b/osm_mon/core/message_bus/consumer.py
index 1ccf936..c0a9dd0 100644
--- a/osm_mon/core/message_bus/consumer.py
+++ b/osm_mon/core/message_bus/consumer.py
@@ -10,6 +10,6 @@ class Consumer(KafkaConsumer):
         super().__init__(bootstrap_servers=cfg.BROKER_URI,
                          key_deserializer=bytes.decode,
                          value_deserializer=bytes.decode,
-                         max_poll_interval_ms=900000,
+                         max_poll_interval_ms=180000,
                          group_id=group_id,
                          **kwargs)