commit 59c6f793318bb42f2b311b37ef9c6fc3ceebe36f
author Benjamin Diaz <bdiaz@whitestack.com> Tue Oct 09 20:22:04 2018 -0300
committer Benjamin Diaz <bdiaz@whitestack.com> Tue Oct 09 20:22:04 2018 -0300
tree 68efca4f8a8008fe64f5059fa56c9df300f70bf3
parent 53ad3c4c5d87a5b392a74cf386c29c67276ed3cb

Increases Kafka session_timeout_ms and heartbeat_interval_ms

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

osm_mon/core/message_bus/common_consumer.py

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 @@
         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)