more fixes

src/KafkaFlow.Abstractions/IConsumerContext.cs

@@ -1,7 +1,6 @@
 namespace KafkaFlow
 {
     using System;
-    using System.Collections.Generic;
     using System.Threading;
     using System.Threading.Tasks;
 

src/KafkaFlow.Abstractions/IProducerContext.cs

@@ -1,7 +1,5 @@
 namespace KafkaFlow;
 
-using System.Collections.Generic;
-
 /// <summary>
 /// Some producer metadata
 /// </summary>

src/KafkaFlow.OpenTelemetry/ActivitySourceAccessor.cs

@@ -5,6 +5,7 @@ namespace KafkaFlow.OpenTelemetry
     using System;
     using System.Collections.Generic;
     using System.Diagnostics;
+    using System.Linq;
     using System.Reflection;
     using Conventions = SemanticConventions::OpenTelemetry.Trace.TraceSemanticConventions;
 
@@ -24,7 +25,7 @@ internal static class ActivitySourceAccessor
         public static void SetGenericTags(Activity activity, IEnumerable<string> bootstrapServers)
         {
             activity?.SetTag(Conventions.AttributeMessagingSystem, MessagingSystemId);
-            activity?.SetTag(Conventions.AttributePeerService, string.Join(",", bootstrapServers));
+            activity?.SetTag(Conventions.AttributePeerService, string.Join(",", bootstrapServers ?? Enumerable.Empty<string>()));
         }
 
         public static ActivityEvent CreateExceptionEvent(Exception exception)

src/KafkaFlow.OpenTelemetry/OpenTelemetryConsumerEventsHandler.cs

@@ -84,16 +84,7 @@ private static IEnumerable<string> ExtractTraceContextIntoBasicProperties(IMessa
 
         private static void SetConsumerTags(IMessageContext context, Activity activity)
         {
-            string messageKey = string.Empty;
-
-            try
-            {
-                messageKey = Encoding.UTF8.GetString(context.Message.Key as byte[]);
-            }
-            catch
-            {
-                // Do nothing
-            }
+            string messageKey = context.Message.Key != null ? Encoding.UTF8.GetString(context.Message.Key as byte[]) : string.Empty;
 
             activity.SetTag(ActivitySourceAccessor.AttributeMessagingOperation, ProcessString);
             activity.SetTag(AttributeMessagingSourceName, context.ConsumerContext.Topic);

src/KafkaFlow/Consumers/ConsumerContext.cs

@@ -1,7 +1,6 @@
 namespace KafkaFlow.Consumers
 {
     using System;
-    using System.Collections.Generic;
     using System.Threading;
     using System.Threading.Tasks;
     using Confluent.Kafka;

src/KafkaFlow/Producers/ProducerContext.cs

@@ -1,12 +1,8 @@
 namespace KafkaFlow.Producers
 {
-    using System.Collections.Generic;
-
     internal class ProducerContext : IProducerContext
     {
-        public ProducerContext(
-            string topic,
-            IDependencyResolver producerDependencyResolver)
+        public ProducerContext(string topic, IDependencyResolver producerDependencyResolver)
         {
             this.Topic = topic;
             this.DependencyResolver = producerDependencyResolver;