Try with embedded kafka

dependencies.gradle

@@ -70,3 +70,4 @@ libraries["wiremock"] = "com.github.tomakehurst:wiremock-standalone:3.0.1"
 libraries["awaitility"] = "org.awaitility:awaitility:4.2.0"
 libraries["splunk-otel-agent"] = 'com.splunk:splunk-otel-javaagent:1.28.0'
 libraries["testcontainers-postgresql"] = 'org.testcontainers:postgresql:1.19.1'
+libraries["embeddedkafka"] = 'io.github.embeddedkafka:embedded-kafka_3:3.6.0'

swatch-producer-aws/build.gradle

@@ -31,12 +31,12 @@ dependencies {
     testImplementation 'io.rest-assured:rest-assured'
     testImplementation 'org.mockito:mockito-junit-jupiter'
     testImplementation 'org.testcontainers:junit-jupiter'
-    testImplementation 'org.testcontainers:kafka'
     testImplementation 'org.testcontainers:postgresql'
     testImplementation 'org.testcontainers:testcontainers'
     testImplementation libraries["junit-jupiter"]
     testImplementation libraries["wiremock"]
     testImplementation project(':swatch-common-testcontainers')
+    testImplementation libraries["embeddedkafka"]
 }
 
 compileJava.dependsOn tasks.openApiGenerate

swatch-producer-aws/src/test/java/com/redhat/swatch/aws/KafkaResource.java

@@ -20,32 +20,28 @@
  */
 package com.redhat.swatch.aws;
 
+import io.github.embeddedkafka.EmbeddedK;
+import io.github.embeddedkafka.EmbeddedKafka;
+import io.github.embeddedkafka.EmbeddedKafkaConfig;
 import io.quarkus.test.common.QuarkusTestResourceLifecycleManager;
 import java.util.Collections;
 import java.util.Map;
-import org.testcontainers.containers.CustomKafkaContainer;
-import org.testcontainers.containers.KafkaContainer;
-import org.testcontainers.utility.DockerImageName;
 
 public class KafkaResource implements QuarkusTestResourceLifecycleManager {
 
-  static KafkaContainer kafka =
-      new CustomKafkaContainer(
-              DockerImageName.parse("quay.io/cloudservices/cp-kafka:latest-ubi8")
-                  .asCompatibleSubstituteFor("confluentinc/cp-kafka"))
-          // SMELL: Workaround for https://github.com/testcontainers/testcontainers-java/issues/7539
-          // This is because testcontainers randomly fails to start a container when using Podman
-          // socket.
-          .withStartupAttempts(3);
+  private EmbeddedK kafka;
 
   @Override
   public Map<String, String> start() {
-    kafka.start();
-    return Collections.singletonMap("kafka.bootstrap.servers", kafka.getBootstrapServers());
+    kafka = EmbeddedKafka.start(EmbeddedKafkaConfig.defaultConfig());
+    return Collections.singletonMap(
+        "kafka.bootstrap.servers", "PLAINTEXT://localhost:" + kafka.config().kafkaPort());
   }
 
   @Override
   public void stop() {
-    kafka.stop();
+    if (kafka != null) {
+      kafka.stop(false);
+    }
   }
 }