diff --git a/dd-java-agent/agent-bootstrap/src/main/java/datadog/trace/bootstrap/Agent.java b/dd-java-agent/agent-bootstrap/src/main/java/datadog/trace/bootstrap/Agent.java index 69156ff9393..78a069f8c33 100644 --- a/dd-java-agent/agent-bootstrap/src/main/java/datadog/trace/bootstrap/Agent.java +++ b/dd-java-agent/agent-bootstrap/src/main/java/datadog/trace/bootstrap/Agent.java @@ -234,6 +234,12 @@ public static void start( propertyNameToSystemPropertyName("integration.spark.enabled"), "true"); setSystemPropertyDefault( propertyNameToSystemPropertyName("integration.spark-executor.enabled"), "true"); + // needed for e2e pipeline + setSystemPropertyDefault(propertyNameToSystemPropertyName("data.streams.enabled"), "true"); + setSystemPropertyDefault( + propertyNameToSystemPropertyName("integration.aws-sdk.enabled"), "true"); + setSystemPropertyDefault( + propertyNameToSystemPropertyName("integration.kafka.enabled"), "true"); String javaCommand = System.getProperty("sun.java.command"); String dataJobsCommandPattern = Config.get().getDataJobsCommandPattern();