From 8804383b38b5616ea5b62d755ad2c784a7bcd5d6 Mon Sep 17 00:00:00 2001 From: kruskal <99559985+kruskall@users.noreply.github.com> Date: Wed, 12 Jun 2024 04:29:38 +0200 Subject: [PATCH] fix: update observer method name --- internal/beater/beatertest/output.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/beater/beatertest/output.go b/internal/beater/beatertest/output.go index 6775a5cbc3a..f37061fa577 100644 --- a/internal/beater/beatertest/output.go +++ b/internal/beater/beatertest/output.go @@ -104,7 +104,7 @@ func (nullOutput) Close() error { func (o nullOutput) Publish(_ context.Context, batch publisher.Batch) error { events := batch.Events() o.observer.NewBatch(len(events)) - o.observer.Acked(len(events)) + o.observer.AckedEvents(len(events)) batch.ACK() return nil }