Skip to content

Commit

Permalink
Maybe the -1 is good
Browse files Browse the repository at this point in the history
  • Loading branch information
elffjs committed Nov 6, 2024
1 parent 29d3991 commit ce84fa9
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion cmd/devices-api/find_old_style_tasks.go
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,7 @@ func (fost *findOldStyleTasks) Execute(_ context.Context, _ *flag.FlagSet, _ ...
}

for m := range pc.Messages() {
if m.Offset >= hwm {
if m.Offset >= hwm-1 {
fost.logger.Info().Msgf("Finished processing partition %d.", p)
break
}
Expand Down

0 comments on commit ce84fa9

Please sign in to comment.