From 8bfea32f5569bccc9277f9bc8bcd25a9fafa610d Mon Sep 17 00:00:00 2001
From: Selamanse <selamanse@scheinfrei.info>
Date: Fri, 25 Oct 2024 20:57:10 +0200
Subject: [PATCH] perf: Use kafka-native container image for Kafka only ITs

---
 pom.xml                                                    | 2 +-
 .../jikkou/kafka/AbstractKafkaIntegrationTest.java         | 7 +++----
 2 files changed, 4 insertions(+), 5 deletions(-)

diff --git a/pom.xml b/pom.xml
index bccc9839b..9f82e3b9a 100644
--- a/pom.xml
+++ b/pom.xml
@@ -112,7 +112,7 @@
         <!-- Tests -->
         <junit.version>5.10.0</junit.version>
         <junit-bom.version>5.10.2</junit-bom.version>
-        <testcontainer.version>1.19.8</testcontainer.version>
+        <testcontainer.version>1.20.2</testcontainer.version>
         <!-- Dependencies -->
         <kafka.version>3.7.0</kafka.version>
         <picocli.version>4.7.6</picocli.version>
diff --git a/providers/jikkou-provider-kafka/src/integration-test/java/io/streamthoughts/jikkou/kafka/AbstractKafkaIntegrationTest.java b/providers/jikkou-provider-kafka/src/integration-test/java/io/streamthoughts/jikkou/kafka/AbstractKafkaIntegrationTest.java
index 30b65e57a..d7094171d 100644
--- a/providers/jikkou-provider-kafka/src/integration-test/java/io/streamthoughts/jikkou/kafka/AbstractKafkaIntegrationTest.java
+++ b/providers/jikkou-provider-kafka/src/integration-test/java/io/streamthoughts/jikkou/kafka/AbstractKafkaIntegrationTest.java
@@ -21,11 +21,11 @@
 import org.junit.jupiter.api.TestMethodOrder;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.testcontainers.containers.KafkaContainer;
 import org.testcontainers.containers.Network;
 import org.testcontainers.containers.output.Slf4jLogConsumer;
 import org.testcontainers.junit.jupiter.Container;
 import org.testcontainers.junit.jupiter.Testcontainers;
+import org.testcontainers.kafka.KafkaContainer;
 import org.testcontainers.utility.DockerImageName;
 
 @Testcontainers
@@ -35,14 +35,13 @@ public class AbstractKafkaIntegrationTest {
     private static final Logger LOG = LoggerFactory.getLogger(AbstractKafkaIntegrationTest.class);
     private static final Network KAFKA_NETWORK = Network.newNetwork();
 
-    public static final String CONFLUENT_PLATFORM_VERSION = "7.4.0";
+    public static final String APACHE_KAFKA_VERSION = "3.8.0";
     public static final int DEFAULT_NUM_PARTITIONS = 1;
     public static final short DEFAULT_REPLICATION_FACTOR = (short) 1;
 
     @Container
     final KafkaContainer kafka = new KafkaContainer(
-            DockerImageName.parse("confluentinc/cp-kafka").withTag(CONFLUENT_PLATFORM_VERSION))
-            .withKraft()
+            DockerImageName.parse("apache/kafka-native").withTag(APACHE_KAFKA_VERSION))
             .withNetwork(KAFKA_NETWORK)
             .withEnv("KAFKA_TRANSACTION_STATE_LOG_MIN_ISR", "1")
             .withEnv("KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR", "1")