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 }