diff --git a/x/batcher/batcher_test.go b/x/batcher/batcher_test.go index fb94c57..fe4297b 100644 --- a/x/batcher/batcher_test.go +++ b/x/batcher/batcher_test.go @@ -341,7 +341,7 @@ func TestBatcherErrors(t *testing.T) { assert.ErrorIs(t, err, flushErr) }) - t.Run("Don't ack messages if flush handler returns ErrRetryable", func(t *testing.T) { + t.Run("Don't ack messages if flush handler returns ErrDontAck", func(t *testing.T) { var retryHandler = func(ctx context.Context, err error, msgs []kawa.Message[string]) error { return ErrDontAck }