From 2689ce007ae833e58cbfd692604782d1f3b1b162 Mon Sep 17 00:00:00 2001 From: Juan Pablo Balarini Date: Thu, 27 Dec 2018 16:14:50 -0300 Subject: [PATCH] Increase session.timeout.ms for KafkaConsumer --- frontera/contrib/messagebus/kafkabus.py | 1 + 1 file changed, 1 insertion(+) diff --git a/frontera/contrib/messagebus/kafkabus.py b/frontera/contrib/messagebus/kafkabus.py index f4761e052..7eedc8fad 100644 --- a/frontera/contrib/messagebus/kafkabus.py +++ b/frontera/contrib/messagebus/kafkabus.py @@ -50,6 +50,7 @@ def __init__(self, location, enable_ssl, cert_path, topic, group, partition_id): client_id="%s-%s" % (self._topic, str(partition_id) if partition_id is not None else "all"), request_timeout_ms=120 * 1000, heartbeat_interval_ms=10000, + session_timeout_ms= 10000 * 3 **kwargs )