From 23c37455e57c424ef09d5f1ce4fafc12b39cae69 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Sim=C3=A3o=20Ribeiro?= <simao.ribeiro@farfetch.com>
Date: Wed, 11 Oct 2023 13:00:48 +0100
Subject: [PATCH] Remove unused creation tags

---
 .../KafkaFlowActivitySourceHelper.cs                       | 7 +------
 1 file changed, 1 insertion(+), 6 deletions(-)

diff --git a/src/KafkaFlow.OpenTelemetry/KafkaFlowActivitySourceHelper.cs b/src/KafkaFlow.OpenTelemetry/KafkaFlowActivitySourceHelper.cs
index e7c24afa8..fd8f37ad9 100644
--- a/src/KafkaFlow.OpenTelemetry/KafkaFlowActivitySourceHelper.cs
+++ b/src/KafkaFlow.OpenTelemetry/KafkaFlowActivitySourceHelper.cs
@@ -16,15 +16,10 @@ internal static class KafkaFlowActivitySourceHelper
         internal static readonly string KafkaString = "kafka";
         internal static readonly string Version = Assembly.GetExecutingAssembly().GetName().Version.ToString();
         internal static readonly ActivitySource ActivitySource = new(KafkaFlowString, Version);
-        internal static readonly IEnumerable<KeyValuePair<string, object>> CreationTags = new[]
-        {
-            new KeyValuePair<string, object>(Conventions.AttributePeerService, KafkaString),
-            new KeyValuePair<string, object>(Conventions.AttributeMessagingSystem, KafkaString),
-        };
 
         public static void SetGenericTags(Activity activity)
         {
-            activity?.SetTag("messaging.system", KafkaString);
+            activity?.SetTag(Conventions.AttributeMessagingSystem, KafkaString);
         }
 
         public static ActivityEvent CreateExceptionEvent(Exception exception)