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 )