fix(transform): Add SkipMissingValues Flag

brexhq · Nov 7, 2024 · 6276aff · 6276aff
1 parent 56584c5
commit 6276aff
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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
 	}