Skip to content

Commit

Permalink
consumer group: no longer un-dirty prior dirty when returning from poll
Browse files Browse the repository at this point in the history
As follow up to c6df11d, since we un-dirty when we enter polling, there
is no reason to un-dirty when we leave. This makes things a bit clearer
as to when things happen.
  • Loading branch information
twmb committed Sep 1, 2021
1 parent a478251 commit 0eaf03a
Showing 1 changed file with 0 additions and 1 deletion.
1 change: 0 additions & 1 deletion pkg/kgo/consumer_group.go
Original file line number Diff line number Diff line change
Expand Up @@ -1348,7 +1348,6 @@ func (g *groupConsumer) updateUncommitted(fetches Fetches) {
}
}

prior.head = prior.dirty
prior.dirty = set
if setHead {
prior.head = set
Expand Down

0 comments on commit 0eaf03a

Please sign in to comment.