From 2fbbda5eef6f6d9a2bcd3e63468ab76c37874903 Mon Sep 17 00:00:00 2001 From: Hamdan Javeed Date: Sat, 23 Mar 2024 04:48:01 -0400 Subject: [PATCH] fix: clear lastAssigned when revoking eager consumer Fixes #686 --- pkg/kgo/consumer_group.go | 1 + 1 file changed, 1 insertion(+) diff --git a/pkg/kgo/consumer_group.go b/pkg/kgo/consumer_group.go index cd76684b..dd95ff48 100644 --- a/pkg/kgo/consumer_group.go +++ b/pkg/kgo/consumer_group.go @@ -639,6 +639,7 @@ func (g *groupConsumer) revoke(stage revokeStage, lost map[string][]int32, leavi g.cfg.onRevoked(g.cl.ctx, g.cl, g.nowAssigned.read()) } g.nowAssigned.store(nil) + g.lastAssigned = nil // After nilling uncommitted here, nothing should recreate // uncommitted until a future fetch after the group is