fix metadatacopy to actually copy the payload and not reference it

trivago · Aug 15, 2017 · 68e98ee · 68e98ee
1 parent bf4c10a
commit 68e98ee
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/format/metadatacopy.go b/format/metadatacopy.go
@@ -66,8 +66,12 @@ func (format *MetadataCopy) Configure(conf core.PluginConfigReader) {
 func (format *MetadataCopy) ApplyFormatter(msg *core.Message) error {
 	meta := msg.GetMetadata()
 	data := format.GetAppliedContent(msg)
+	pool := core.MessageDataPool
+
 	for _, key := range format.metaDataKeys {
-		meta.SetValue(key, data)
+		bufferCopy := pool.Get(len(data))
+		copy(bufferCopy, data)
+		meta.SetValue(key, bufferCopy)
 	}
 	return nil
 }