Merge pull request #720 from hamdanjaveed/master

fix: clear lastAssigned when revoking eager consumer
twmb · May 26, 2024 · 4ccdc73 · 4ccdc73
2 parents 48855f9 + 2fbbda5
commit 4ccdc73
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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