no need for docker config

Author: zeitlinger

.github/workflows/reusable-native-tests.yml

@@ -24,8 +24,4 @@ jobs:
           echo "JAVA_HOME: $JAVA_HOME"
           java --version
           native-image --version
-          # Testcontainers does not work with native-image, 
-          # therefore we're starting a Kafka container manually for the tests
-          docker run -d -p 9092:9092 --name kafka --rm confluentinc/cp-kafka:6.2.10
           ./gradlew nativeTest
-          docker stop kafka # is this needed?

smoke-tests-otel-starter/spring-boot-3/src/test/java/io/opentelemetry/smoketest/GraalVmNativeKafkaSpringStarterSmokeTest.java

@@ -18,18 +18,33 @@
 import org.junit.jupiter.api.Test;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.boot.testcontainers.service.connection.ServiceConnection;
 import org.springframework.kafka.core.KafkaTemplate;
+import org.testcontainers.containers.KafkaContainer;
+import org.testcontainers.containers.wait.strategy.Wait;
+import org.testcontainers.junit.jupiter.Container;
+import org.testcontainers.junit.jupiter.Testcontainers;
+import org.testcontainers.utility.DockerImageName;
+import java.time.Duration;
 
+@Testcontainers
 @SpringBootTest(
     classes = {OtelSpringStarterSmokeTestApplication.class, SpringSmokeOtelConfiguration.class},
     webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT, properties = {
       "spring.kafka.consumer.auto-offset-reset=earliest",
       "spring.kafka.consumer.linger-ms=10",
+      "spring.kafka.admin.operation-timeout=5m",
       "spring.kafka.listener.idle-between-polls=1000",
       "spring.kafka.producer.transaction-id-prefix=test-"
 
 })
-abstract class AbstractKafkaSpringStarterSmokeTest extends AbstractSpringStarterSmokeTest {
+public class KafkaSpringStarterSmokeTest extends AbstractSpringStarterSmokeTest {
+
+  @Container @ServiceConnection
+  static KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:6.2.10"))
+      .withEnv("KAFKA_HEAP_OPTS", "-Xmx256m")
+      .waitingFor(Wait.forLogMessage(".*started \\(kafka.server.KafkaServer\\).*", 1))
+      .withStartupTimeout(Duration.ofMinutes(1));
 
   @Autowired private KafkaTemplate<String, String> kafkaTemplate;