diff --git a/src/KafkaFlow.ApplicationInsights/AppInsightsConsumerEventsHandler.cs b/src/KafkaFlow.ApplicationInsights/AppInsightsConsumerEventsHandler.cs index aa6683d..3917055 100644 --- a/src/KafkaFlow.ApplicationInsights/AppInsightsConsumerEventsHandler.cs +++ b/src/KafkaFlow.ApplicationInsights/AppInsightsConsumerEventsHandler.cs @@ -26,7 +26,7 @@ public static Task OnConsumeError(IMessageContext eventContextMessageContext, Ex eventContextMessageContext.Items.TryGetValue("timer", out var timer); var theTimer = (Stopwatch)timer; theTimer.Stop(); - telemetryClient.TrackKafkaDependency(eventContextMessageContext, "500", false, theTimer.Elapsed); + telemetryClient.TrackKafkaDependency(eventContextMessageContext, "Error", false, theTimer.Elapsed); return Task.CompletedTask; } @@ -38,7 +38,7 @@ internal static Task OnConsumeCompleted(IMessageContext eventContextMessageConte var theTimer = (Stopwatch)timer; theTimer.Stop(); - telemetryClient.TrackKafkaDependency(eventContextMessageContext, "200", true, theTimer.Elapsed); + telemetryClient.TrackKafkaDependency(eventContextMessageContext, "Ok", true, theTimer.Elapsed); return Task.CompletedTask; } } diff --git a/src/KafkaFlow.ApplicationInsights/AppInsightsProducerEventsHandler.cs b/src/KafkaFlow.ApplicationInsights/AppInsightsProducerEventsHandler.cs index b9677a1..5e1215d 100644 --- a/src/KafkaFlow.ApplicationInsights/AppInsightsProducerEventsHandler.cs +++ b/src/KafkaFlow.ApplicationInsights/AppInsightsProducerEventsHandler.cs @@ -27,7 +27,7 @@ public static Task OnProducerError(IMessageContext eventContextMessageContext, E var theTimer = (Stopwatch)timer; theTimer.Stop(); - telemetryClient.TrackKafkaDependency(eventContextMessageContext, "500", false, theTimer.Elapsed); + telemetryClient.TrackKafkaDependency(eventContextMessageContext, "Error", false, theTimer.Elapsed); return Task.CompletedTask; } @@ -39,7 +39,7 @@ public static Task OnProducerCompleted(IMessageContext eventContextMessageContex var theTimer = (Stopwatch)timer; theTimer.Stop(); - telemetryClient.TrackKafkaDependency(eventContextMessageContext, "200", true, theTimer.Elapsed); + telemetryClient.TrackKafkaDependency(eventContextMessageContext, "Ok", true, theTimer.Elapsed); return Task.CompletedTask; } }