twmb
diff --git a/‎pkg/kgo/consumer_group.go‎
Lines changed: 1 addition & 0 deletions b/‎pkg/kgo/consumer_group.go‎
Lines changed: 1 addition & 0 deletions
@@ -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
Original file line number	Diff line number	Diff line change
`@@ -639,6 +639,7 @@ func (g *groupConsumer) revoke(stage revokeStage, lost map[string][]int32, leavi`
`639`	`639`	`g.cfg.onRevoked(g.cl.ctx, g.cl, g.nowAssigned.read())`
`640`	`640`	`}`
`641`	`641`	`g.nowAssigned.store(nil)`
	`642`	`+ g.lastAssigned = nil`
`642`	`643`
`643`	`644`	`// After nilling uncommitted here, nothing should recreate`
`644`	`645`	`// uncommitted until a future fetch after the group is`