From 26291c9fca19924a0b358c593e9a5e2e75bf08c0 Mon Sep 17 00:00:00 2001 From: Alexey Shkarupin Date: Tue, 19 Nov 2019 12:39:19 +0200 Subject: [PATCH] explicit version for kafka session timeout --- 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 c4ddf8401..dbda5e02f 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=30000, **kwargs )