Skip to content

Commit

Permalink
implement KIP-735
Browse files Browse the repository at this point in the history
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
  • Loading branch information
twmb committed May 11, 2021
1 parent 36be32e commit faaecd2
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions pkg/kgo/consumer_group.go
Original file line number Diff line number Diff line change
Expand Up @@ -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.
//
Expand Down Expand Up @@ -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,

Expand Down

0 comments on commit faaecd2

Please sign in to comment.