X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;ds=sidebyside;f=osm_mon%2Fcore%2Fmessage_bus%2Fconsumer.py;h=1ccf936e1fd271cf3bb7df57f1bfef00b5ff8f98;hb=refs%2Fchanges%2F66%2F6766%2F7;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..1ccf936 100644 --- a/osm_mon/core/message_bus/consumer.py +++ b/osm_mon/core/message_bus/consumer.py @@ -5,11 +5,11 @@ from osm_mon.core.settings import Config # noinspection PyAbstractClass class Consumer(KafkaConsumer): - def __init__(self, group_id): + def __init__(self, group_id, **kwargs): cfg = Config.instance() super().__init__(bootstrap_servers=cfg.BROKER_URI, key_deserializer=bytes.decode, value_deserializer=bytes.decode, + max_poll_interval_ms=900000, group_id=group_id, - session_timeout_ms=60000, - heartbeat_interval_ms=20000) + **kwargs)