From faaecd28df0238ac46301a4e7d1b57866db2c78b Mon Sep 17 00:00:00 2001 From: Travis Bischel Date: Tue, 11 May 2021 15:14:08 -0600 Subject: [PATCH] implement KIP-735 This is a small change to bump the session timeout from a default of 10s to a default of 45s; see the KIP for more reasoning details --- pkg/kgo/consumer_group.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/kgo/consumer_group.go b/pkg/kgo/consumer_group.go index 36c37daf..402dd2a8 100644 --- a/pkg/kgo/consumer_group.go +++ b/pkg/kgo/consumer_group.go @@ -58,7 +58,7 @@ func Balancers(balancers ...GroupBalancer) GroupOpt { } // SessionTimeout sets how long a member the group can go between heartbeats, -// overriding the default 10,000ms. If a member does not heartbeat in this +// overriding the default 45,000ms. If a member does not heartbeat in this // timeout, the broker will remove the member from the group and initiate a // rebalance. // @@ -386,7 +386,7 @@ func (cl *Client) AssignGroup(group string, opts ...GroupOpt) { rejoinCh: make(chan struct{}, 1), reSeen: make(map[string]struct{}), - sessionTimeout: 10000 * time.Millisecond, + sessionTimeout: 45000 * time.Millisecond, rebalanceTimeout: 60000 * time.Millisecond, heartbeatInterval: 3000 * time.Millisecond,