From: Benjamin Diaz <bdiaz@whitestack.com>
Date: Tue, 9 Oct 2018 23:22:04 +0000 (-0300)
Subject: Increases Kafka session_timeout_ms and heartbeat_interval_ms
X-Git-Tag: v5.0.0~31
X-Git-Url: https://osm.etsi.org/gitweb/?a=commitdiff_plain;h=59c6f793318bb42f2b311b37ef9c6fc3ceebe36f;p=osm%2FMON.git

Increases Kafka session_timeout_ms and heartbeat_interval_ms

Signed-off-by: Benjamin Diaz <bdiaz@whitestack.com>
---

diff --git a/osm_mon/core/message_bus/common_consumer.py b/osm_mon/core/message_bus/common_consumer.py
index cdc8548..3af2d4a 100755
--- a/osm_mon/core/message_bus/common_consumer.py
+++ b/osm_mon/core/message_bus/common_consumer.py
@@ -106,7 +106,9 @@ class CommonConsumer:
         common_consumer = KafkaConsumer(bootstrap_servers=cfg.BROKER_URI,
                                         key_deserializer=bytes.decode,
                                         value_deserializer=bytes.decode,
-                                        group_id="mon-consumer")
+                                        group_id="mon-consumer",
+                                        session_timeout_ms=60000,
+                                        heartbeat_interval_ms=20000)
 
         topics = ['metric_request', 'alarm_request', 'vim_account']
         common_consumer.subscribe(topics)