add a check to ensure that code origin is enabled before trying to apply the advice

evanchooly · evanchooly · commit 979e40ccc968 · 2025-02-11T13:54:39.000-05:00
diff --git a/dd-java-agent/instrumentation/kafka-clients-3.8/src/main/java/datadog/trace/instrumentation/kafka_clients38/MessageListenerInstrumentation.java b/dd-java-agent/instrumentation/kafka-clients-3.8/src/main/java/datadog/trace/instrumentation/kafka_clients38/MessageListenerInstrumentation.java
@@ -8,6 +8,7 @@
 import com.google.auto.service.AutoService;
 import datadog.trace.agent.tooling.Instrumenter;
 import datadog.trace.agent.tooling.InstrumenterModule;
+import datadog.trace.api.InstrumenterConfig;
 import net.bytebuddy.description.type.TypeDescription;
 import net.bytebuddy.matcher.ElementMatcher;
 
@@ -19,6 +20,11 @@ public MessageListenerInstrumentation() {
     super("kafka", "kafka-3.8");
   }
 
+  @Override
+  public boolean isEnabled() {
+    return InstrumenterConfig.get().isCodeOriginEnabled() && super.isEnabled();
+  }
+
   @Override
   public ElementMatcher.Junction<ClassLoader> classLoaderMatcher() {
     return hasClassNamed("org.apache.kafka.clients.MetadataRecoveryStrategy"); // since 3.8
