do not mutate messages

open-telemetry · Apr 29, 2024 · d161c6b · d161c6b
1 parent 8784607
commit d161c6b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/exporter/kafkaexporter/pdata_marshaler.go b/exporter/kafkaexporter/pdata_marshaler.go
@@ -71,7 +71,7 @@ func (p pdataMetricsMarshaler) Marshal(ld pmetric.Metrics, topic string) ([]*sar
 			var hash = pdatautil.MapHash(resourceMetrics.Resource().Attributes())
 
 			newMetrics := pmetric.NewMetrics()
-			resourceMetrics.MoveTo(newMetrics.ResourceMetrics().AppendEmpty())
+			resourceMetrics.CopyTo(newMetrics.ResourceMetrics().AppendEmpty())
 
 			bts, err := p.marshaler.MarshalMetrics(newMetrics)
 			if err != nil {