refactors

src/KafkaFlow.Abstractions/ActivitySourceAccessor.cs

@@ -3,10 +3,22 @@
     using System.Diagnostics;
     using System.Reflection;
 
+    /// <summary>
+    /// ActivitySource properties
+    /// </summary>
     public static class ActivitySourceAccessor
     {
-        public const string ActivityString = "otel_activity";
-        public static readonly ActivitySource ActivitySource = new("KafkaFlow.OpenTelemetry", Version);
+        /// <summary>
+        /// The name of the OpenTelemetry Activity that is used as a key
+        /// in MessageContext.Items dictionary
+        /// </summary>
+        public static string ActivityString = "otel_activity";
+
+        /// <summary>
+        /// The ActivitySource name that is used in KafkaFlow
+        /// </summary>
+        public static ActivitySource ActivitySource = new("KafkaFlow.OpenTelemetry", Version);
+
         internal static readonly string Version = Assembly.GetExecutingAssembly().GetName().Version.ToString();
     }
 }

src/KafkaFlow.OpenTelemetry/OpenTelemetryConsumerEventsHandler.cs

@@ -84,7 +84,7 @@ private static void SetConsumerTags(IMessageContext context, Activity activity)
         {
             var messageKey = Encoding.UTF8.GetString(context.Message.Key as byte[]);
 
-            activity.SetTag(ActivityAccessor.AttributeMessagingOperation, ActivityOperationType.Process);
+            activity.SetTag(ActivityAccessor.AttributeMessagingOperation, ActivityOperationType.Process.ToString().ToLower());
             activity.SetTag(AttributeMessagingSourceName, context.ConsumerContext.Topic);
             activity.SetTag(AttributeMessagingKafkaConsumerGroup, context.ConsumerContext.GroupId);
             activity.SetTag(ActivityAccessor.AttributeMessagingKafkaMessageKey, messageKey);

src/KafkaFlow.OpenTelemetry/OpenTelemetryProducerEventsHandler.cs

@@ -89,7 +89,7 @@ private static void InjectTraceContextIntoBasicProperties(IMessageContext contex
 
         private static void SetProducerTags(IMessageContext context, Activity activity)
         {
-            activity.SetTag(ActivityAccessor.AttributeMessagingOperation, ActivityOperationType.Publish);
+            activity.SetTag(ActivityAccessor.AttributeMessagingOperation, ActivityOperationType.Publish.ToString().ToLower());
             activity.SetTag(AttributeMessagingDestinationName, context?.ProducerContext.Topic);
             activity.SetTag(AttributeMessagingKafkaDestinationPartition, context?.ProducerContext.Partition);
             activity.SetTag(ActivityAccessor.AttributeMessagingKafkaMessageKey, context?.Message.Key);

src/KafkaFlow/ActivityFactory.cs

@@ -6,7 +6,7 @@ internal class ActivityFactory : IActivityFactory
     {
         public Activity Start(string topicName, ActivityOperationType activityOperationType, ActivityKind activityKind)
         {
-            var activityName = !string.IsNullOrEmpty(topicName) ? $"{topicName} {activityOperationType}" : activityOperationType.ToString();
+            var activityName = !string.IsNullOrEmpty(topicName) ? $"{topicName} {activityOperationType}" : activityOperationType.ToString().ToLower();
 
             // Start an activity with a name following the semantic convention of the OpenTelemetry messaging specification.
             // The convention also defines a set of attributes (in .NET they are mapped as `tags`) to be populated in the activity.

src/KafkaFlow/IActivityFactory.cs

@@ -1,10 +1,9 @@
-using System.Diagnostics;
-
-namespace KafkaFlow
+namespace KafkaFlow
 {
+    using System.Diagnostics;
+
     internal interface IActivityFactory
     {
-
         public Activity Start(string topicName, ActivityOperationType activityOperationType, ActivityKind activityKind);
     }
 }