From e8633ebb3e7074e7a95288d2a67d00535885f058 Mon Sep 17 00:00:00 2001 From: Marty Tippin <120425148+tippmar-nr@users.noreply.github.com> Date: Tue, 16 Jul 2024 14:22:45 -0500 Subject: [PATCH] cleanup --- .../Extensions/Providers/Wrapper/Kafka/KafkaConsumerWrapper.cs | 1 - .../Extensions/Providers/Wrapper/Kafka/KafkaProducerWrapper.cs | 1 - 2 files changed, 2 deletions(-) diff --git a/src/Agent/NewRelic/Agent/Extensions/Providers/Wrapper/Kafka/KafkaConsumerWrapper.cs b/src/Agent/NewRelic/Agent/Extensions/Providers/Wrapper/Kafka/KafkaConsumerWrapper.cs index 57746d7d6..d20b2eeab 100644 --- a/src/Agent/NewRelic/Agent/Extensions/Providers/Wrapper/Kafka/KafkaConsumerWrapper.cs +++ b/src/Agent/NewRelic/Agent/Extensions/Providers/Wrapper/Kafka/KafkaConsumerWrapper.cs @@ -66,7 +66,6 @@ public AfterWrappedMethodDelegate BeforeWrappedMethod(InstrumentedMethodCall ins segment.SetMessageBrokerDestination(topic); transaction.SetKafkaMessageBrokerTransactionName(MessageBrokerDestinationType.Topic, BrokerVendorName, topic); - // add a supportability metric for the bootstrap servers associated with this consumer instance if (KafkaHelper.TryGetBootstrapServersFromCache(instrumentedMethodCall.MethodCall.InvocationTarget, out var bootstrapServers)) { KafkaHelper.RecordKafkaNodeMetrics(agent, topic, bootstrapServers, false); diff --git a/src/Agent/NewRelic/Agent/Extensions/Providers/Wrapper/Kafka/KafkaProducerWrapper.cs b/src/Agent/NewRelic/Agent/Extensions/Providers/Wrapper/Kafka/KafkaProducerWrapper.cs index 47cd5e00a..d409a67a2 100644 --- a/src/Agent/NewRelic/Agent/Extensions/Providers/Wrapper/Kafka/KafkaProducerWrapper.cs +++ b/src/Agent/NewRelic/Agent/Extensions/Providers/Wrapper/Kafka/KafkaProducerWrapper.cs @@ -31,7 +31,6 @@ public AfterWrappedMethodDelegate BeforeWrappedMethod(InstrumentedMethodCall ins transaction.InsertDistributedTraceHeaders(messageMetadata, DistributedTraceHeadersSetter); - // add a supportability metric for the bootstrap servers associated with this producer instance if (KafkaHelper.TryGetBootstrapServersFromCache(instrumentedMethodCall.MethodCall.InvocationTarget, out var bootstrapServers)) { KafkaHelper.RecordKafkaNodeMetrics(agent, topicPartition.Topic, bootstrapServers, true);