X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_mon%2Fcore%2Fmessage_bus%2Fconsumer.py;h=c0a9dd0ca59bdd0b316333771671e7e52132d67f;hb=0e34244e420bd68e6acb0cf6bb4383fedb662070;hp=363b9fc7fb0a5bb6b13afeba51fc3296aae07088;hpb=8280121bd3684354e83cd43eb91ad616405e2e8d;p=osm%2FMON.git diff --git a/osm_mon/core/message_bus/consumer.py b/osm_mon/core/message_bus/consumer.py index 363b9fc..c0a9dd0 100644 --- a/osm_mon/core/message_bus/consumer.py +++ b/osm_mon/core/message_bus/consumer.py @@ -5,9 +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, - group_id=group_id) + max_poll_interval_ms=180000, + group_id=group_id, + **kwargs)