fix: update observer method name

elastic · Jun 12, 2024 · 8804383 · 8804383
1 parent 89586e7
commit 8804383
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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
 }