Skip to content

Commit 462a857

Browse files
Revert transaction check logic
1 parent af930e3 commit 462a857

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

instrumentation/kafka-clients-spans-0.11.0.0/src/main/java/org/apache/kafka/clients/producer/KafkaProducer_Instrumentation.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,8 @@
77

88
package org.apache.kafka.clients.producer;
99

10+
import com.newrelic.agent.bridge.AgentBridge;
11+
import com.newrelic.agent.bridge.Transaction;
1012
import com.newrelic.api.agent.Headers;
1113
import com.newrelic.api.agent.NewRelic;
1214
import com.newrelic.api.agent.Trace;
@@ -21,7 +23,8 @@ public class KafkaProducer_Instrumentation<K, V> {
2123

2224
@Trace
2325
private Future<RecordMetadata> doSend(ProducerRecord record, Callback callback) {
24-
if (NewRelic.getAgent().getTransaction() != null) {
26+
final Transaction transaction = AgentBridge.getAgent().getTransaction(false);
27+
if (transaction != null) {
2528
Headers dtHeaders = new HeadersWrapper(record.headers());
2629
NewRelic.getAgent().getTransaction().insertDistributedTraceHeaders(dtHeaders);
2730
}

0 commit comments

Comments
 (0)