diff --git a/pkg/processor/batch.go b/pkg/processor/batch.go index a5e6b608..8baed6e3 100644 --- a/pkg/processor/batch.go +++ b/pkg/processor/batch.go @@ -382,6 +382,8 @@ func (bvp *BatchItemProcessor[T]) batchBuilder(ctx context.Context) { bvp.batchReady <- true } + bvp.timer.Reset(bvp.o.BatchTimeout) + bvp.batchMutex.Unlock() } }