Adds OSMMON_VCA_USER and adds timeout and max.poll.interval to collector

[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 7936513..1ccf936 100644 (file)
--- a/osm_mon/core/message_bus/consumer.py
+++ b/osm_mon/core/message_bus/consumer.py
@@ -5,10 +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)
+                         group_id=group_id,
+                         **kwargs)