fix

Farfetch · Oct 17, 2023 · 2e2a718 · 2e2a718
1 parent 37cfe2c
commit 2e2a718
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/KafkaFlow.OpenTelemetry/OpenTelemetryConsumerEventsHandler.cs b/src/KafkaFlow.OpenTelemetry/OpenTelemetryConsumerEventsHandler.cs
@@ -57,7 +57,7 @@ public static Task OnConsumeCompleted(IMessageContext context)
         {
             if (context.Items.TryGetValue(ActivitySourceAccessor.ActivityString, out var value) && value is Activity activity)
             {
-                activity?.Stop();
+                //activity?.Stop();
             }
 
             return Task.CompletedTask;
@@ -71,7 +71,7 @@ public static Task OnConsumeError(IMessageContext context, Exception ex)
 
                 activity?.AddEvent(exceptionEvent);
 
-                activity?.Stop();
+                //activity?.Stop();
             }
 
             return Task.CompletedTask;

diff --git a/src/KafkaFlow.OpenTelemetry/OpenTelemetryProducerEventsHandler.cs b/src/KafkaFlow.OpenTelemetry/OpenTelemetryProducerEventsHandler.cs
@@ -67,7 +67,7 @@ public static Task OnProducerCompleted(IMessageContext context)
         {
             if (context.Items.TryGetValue(ActivitySourceAccessor.ActivityString, out var value) && value is Activity activity)
             {
-                activity?.Stop();
+                //activity?.Stop();
             }
 
             return Task.CompletedTask;
@@ -81,7 +81,7 @@ public static Task OnProducerError(IMessageContext context, Exception ex)
 
                 activity?.AddEvent(exceptionEvent);
 
-                activity?.Stop();
+                //activity?.Stop();
             }
 
             return Task.CompletedTask;