Skip to content

Commit

Permalink
Remove unused creation tags
Browse files Browse the repository at this point in the history
  • Loading branch information
simaoribeiro committed Oct 11, 2023
1 parent 8132202 commit 23c3745
Showing 1 changed file with 1 addition and 6 deletions.
7 changes: 1 addition & 6 deletions src/KafkaFlow.OpenTelemetry/KafkaFlowActivitySourceHelper.cs
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down

0 comments on commit 23c3745

Please sign in to comment.