fix: clone each event in the libbeat publisher processor

kruskall · Aug 31, 2023 · 15613a2 · 15613a2
1 parent bd52e02
commit 15613a2
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/internal/publish/pub.go b/internal/publish/pub.go
@@ -142,7 +142,10 @@ func (p *Publisher) Stop(ctx context.Context) error {
 // publishing pipeline.
 func (p *Publisher) ProcessBatch(ctx context.Context, batch *modelpb.Batch) error {
 	b := make(modelpb.Batch, len(*batch))
-	copy(b, *batch)
+	for i, e := range (*batch) {
+		cp := e.CloneVT()
+		b[i] = cp
+	}
 	return p.Send(ctx, PendingReq{Transformable: batchTransformer(b)})
 }