Skip to content

Commit

Permalink
cmon
Browse files Browse the repository at this point in the history
  • Loading branch information
mapno committed Nov 12, 2024
1 parent 0817cfa commit 5a6cc7c
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion modules/blockbuilder/blockbuilder_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ func TestBlockbuilder(t *testing.T) {
t.Cleanup(k.Close)

kafkaCommits := atomic.NewInt32(0)
k.ControlKey(kmsg.OffsetCommit.Int16(), func(m kmsg.Request) (kmsg.Response, error, bool) {
k.ControlKey(kmsg.OffsetCommit.Int16(), func(kmsg.Request) (kmsg.Response, error, bool) {
kafkaCommits.Add(1)
return nil, nil, false
})
Expand Down

0 comments on commit 5a6cc7c

Please sign in to comment.