fix: clear lastAssigned when revoking eager consumer

Fixes #686
twmb · May 8, 2024 · 2fbbda5 · 2fbbda5
1 parent 8b53958
commit 2fbbda5
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