Skip to content

Commit

Permalink
Fix rewind to latest commit to init correctly, it didn't work in some…
Browse files Browse the repository at this point in the history
… clusters
  • Loading branch information
mdisibio committed Jan 9, 2025
1 parent 6296572 commit b581039
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion modules/blockbuilder/blockbuilder.go
Original file line number Diff line number Diff line change
Expand Up @@ -221,7 +221,7 @@ func (b *BlockBuilder) consumePartition(ctx context.Context, partition int32, ov

lastCommit, ok := commits.Lookup(topic, partition)
if ok && lastCommit.At >= 0 {
startOffset = startOffset.At(lastCommit.At)
startOffset = kgo.NewOffset().At(lastCommit.At)
} else {
startOffset = kgo.NewOffset().AtStart()
}
Expand Down

0 comments on commit b581039

Please sign in to comment.