From 6276aff94985cacfac67d99401e4c673eee66092 Mon Sep 17 00:00:00 2001 From: jshlbrd Date: Thu, 7 Nov 2024 09:43:59 -0800 Subject: [PATCH] fix(transform): Add SkipMissingValues Flag --- transform/test_message.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/transform/test_message.go b/transform/test_message.go index 78f65337..94b817ca 100644 --- a/transform/test_message.go +++ b/transform/test_message.go @@ -44,7 +44,7 @@ type testMessage struct { func (tf *testMessage) Transform(_ context.Context, msg *message.Message) ([]*message.Message, error) { if msg.HasFlag(message.IsControl) { - m := message.New().SetData(anyToBytes(tf.conf.Value)) + m := message.New().SetData(anyToBytes(tf.conf.Value)).SkipMissingValues() return []*message.Message{m, msg}, nil }