fix: replace messaging.type with messaging.system

simaoribeiro · JotaDobleEse · commit c683ddf64d8a · 2025-07-29T23:52:10.000+02:00
diff --git a/src/KafkaFlow.OpenTelemetry/ActivitySourceAccessor.cs b/src/KafkaFlow.OpenTelemetry/ActivitySourceAccessor.cs
@@ -18,7 +18,7 @@ internal static void SetGenericTags(Activity activity, IEnumerable<string> boots
     {
         // https://opentelemetry.io/docs/languages/net/libraries/#note-on-versioning
         // https://github.com/open-telemetry/opentelemetry-dotnet/blob/core-1.9.0/src/Shared/SemanticConventions.cs
-        activity?.SetTag("message.type", MessagingSystemId);
+        activity?.SetTag("messaging.system", MessagingSystemId);
         activity?.SetTag("peer.service", string.Join(",", bootstrapServers ?? Enumerable.Empty<string>()));
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -18,7 +18,7 @@ internal static void SetGenericTags(Activity activity, IEnumerable<string> boots`
`18`	`18`	`{`
`19`	`19`	`// https://opentelemetry.io/docs/languages/net/libraries/#note-on-versioning`
`20`	`20`	`// https://github.com/open-telemetry/opentelemetry-dotnet/blob/core-1.9.0/src/Shared/SemanticConventions.cs`
`21`		`- activity?.SetTag("message.type", MessagingSystemId);`
	`21`	`+ activity?.SetTag("messaging.system", MessagingSystemId);`
`22`	`22`	`activity?.SetTag("peer.service", string.Join(",", bootstrapServers ?? Enumerable.Empty<string>()));`
`23`	`23`	`}`
`24`	`24`	`}`