X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_mon%2Fcore%2Fmessage_bus%2Fconsumer.py;h=79365135a0eec3409cdafe1e2cb29ae05bcca4d7;hb=e592e3ed8c0efa26a3b783163fe43696a4fb7a25;hp=b12cd8881f00967eaeff197bf625678f1c8877bd;hpb=93699898c51364cde193d8d441f4aed45670e7bf;p=osm%2FMON.git

diff --git a/osm_mon/core/message_bus/consumer.py b/osm_mon/core/message_bus/consumer.py
index b12cd88..7936513 100644
--- a/osm_mon/core/message_bus/consumer.py
+++ b/osm_mon/core/message_bus/consumer.py
@@ -10,6 +10,5 @@ class Consumer(KafkaConsumer):
         super().__init__(bootstrap_servers=cfg.BROKER_URI,
                          key_deserializer=bytes.decode,
                          value_deserializer=bytes.decode,
-                         group_id=group_id,
-                         session_timeout_ms=60000,
-                         heartbeat_interval_ms=20000)
+                         max_poll_interval_ms=900000,
+                         group_id=group_id)