Skip to content

Commit 979e40c

Browse files
committed
add a check to ensure that code origin is enabled before trying to apply the advice
1 parent eacd9ae commit 979e40c

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

dd-java-agent/instrumentation/kafka-clients-3.8/src/main/java/datadog/trace/instrumentation/kafka_clients38/MessageListenerInstrumentation.java

+6
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@
88
import com.google.auto.service.AutoService;
99
import datadog.trace.agent.tooling.Instrumenter;
1010
import datadog.trace.agent.tooling.InstrumenterModule;
11+
import datadog.trace.api.InstrumenterConfig;
1112
import net.bytebuddy.description.type.TypeDescription;
1213
import net.bytebuddy.matcher.ElementMatcher;
1314

@@ -19,6 +20,11 @@ public MessageListenerInstrumentation() {
1920
super("kafka", "kafka-3.8");
2021
}
2122

23+
@Override
24+
public boolean isEnabled() {
25+
return InstrumenterConfig.get().isCodeOriginEnabled() && super.isEnabled();
26+
}
27+
2228
@Override
2329
public ElementMatcher.Junction<ClassLoader> classLoaderMatcher() {
2430
return hasClassNamed("org.apache.kafka.clients.MetadataRecoveryStrategy"); // since 3.8

0 commit comments

Comments
 (0)