add init params by jvm args

Author: Cirilla-zmh

messaging-wrappers/kafka-clients/build.gradle.kts

@@ -35,3 +35,13 @@ dependencies {
   testImplementation("io.opentelemetry:opentelemetry-exporter-logging")
   testImplementation("io.opentelemetry.javaagent:opentelemetry-testing-common")
 }
+
+tasks {
+  withType<Test>().configureEach {
+    jvmArgs("-Dotel.java.global-autoconfigure.enabled=true")
+    jvmArgs("-Dotel.instrumentation.messaging.experimental.receive-telemetry.enabled=true")
+    jvmArgs("-Dotel.traces.exporter=logging")
+    jvmArgs("-Dotel.metrics.exporter=logging")
+    jvmArgs("-Dotel.logs.exporter=logging")
+  }
+}

messaging-wrappers/kafka-clients/src/test/java/io/opentelemetry/contrib/messaging/wrappers/kafka/KafkaClientTest.java

@@ -51,22 +51,19 @@ public Map<String, Object> consumerProps() {
 
   @Test
   void testInterceptors() throws InterruptedException {
-    try (AutoConfigTestProperties props = new AutoConfigTestProperties()
-        .put("otel.instrumentation.messaging.experimental.receive-telemetry.enabled", "true")) {
-      OpenTelemetry otel = GlobalOpenTelemetry.get();
-      Tracer tracer = otel.getTracer("test");
-      MessagingProcessWrapper<KafkaProcessRequest> wrapper = KafkaHelper.processWrapperBuilder()
-          .openTelemetry(otel)
-          .build();
+    OpenTelemetry otel = GlobalOpenTelemetry.get();
+    Tracer tracer = otel.getTracer("test");
+    MessagingProcessWrapper<KafkaProcessRequest> wrapper = KafkaHelper.processWrapperBuilder()
+        .openTelemetry(otel)
+        .build();
 
-      sendWithParent(tracer);
+    sendWithParent(tracer);
 
-      awaitUntilConsumerIsReady();
+    awaitUntilConsumerIsReady();
 
-      consumeWithChild(tracer, wrapper);
+    consumeWithChild(tracer, wrapper);
 
-      assertTraces();
-    }
+    assertTraces();
   }
 
   @SuppressWarnings("FutureReturnValueIgnored")