Skip to content

Commit

Permalink
cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
tippmar-nr committed Jul 16, 2024
1 parent 7150963 commit e8633eb
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand Down

0 comments on commit e8633eb

Please sign in to comment.