Allow datapoint attributes to override user.name (#317)

elastic · Jul 9, 2024 · 1542936 · 1542936
1 parent f3eac86
commit 1542936
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/input/otlp/metrics.go b/input/otlp/metrics.go
@@ -240,6 +240,11 @@ func (c *Consumer) handleScopeMetrics(
 						event.Event = modelpb.EventFromVTPool()
 					}
 					event.Event.Dataset = v.Str()
+				case "user.name":
+					if event.User == nil {
+						event.User = modelpb.UserFromVTPool()
+					}
+					event.User.Name = truncate(v.Str())
 				default:
 					setLabel(k, event, ifaceAttributeValue(v))
 				}

diff --git a/input/otlp/metrics_test.go b/input/otlp/metrics_test.go
@@ -1075,9 +1075,6 @@ func TestConsumeMetricsWithOTelRemapper(t *testing.T) {
 					},
 					Labels: map[string]*modelpb.LabelValue{
 						"otel_remapped": &modelpb.LabelValue{Value: "true"},
-						// This is set as labels too since the opentelemetry-lib
-						// adds `user.name` label to datapoints causing duplicates.
-						"user.name": &modelpb.LabelValue{Value: "testowner"},
 					},
 					Event: &modelpb.Event{
 						Dataset: "system.process",