From 59c6f793318bb42f2b311b37ef9c6fc3ceebe36f Mon Sep 17 00:00:00 2001 From: Benjamin Diaz Date: Tue, 9 Oct 2018 20:22:04 -0300 Subject: [PATCH] Increases Kafka session_timeout_ms and heartbeat_interval_ms Signed-off-by: Benjamin Diaz --- osm_mon/core/message_bus/common_consumer.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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) -- 2.25.1