Fix listeners to make it compatible with Apache Kafka 3.9.0

Fixes #9506
testcontainers · Nov 7, 2024 · 41e9ff6 · 41e9ff6
1 parent 0200a5d
commit 41e9ff6
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 5 deletions.
diff --git a/modules/kafka/src/main/java/org/testcontainers/kafka/KafkaHelper.java b/modules/kafka/src/main/java/org/testcontainers/kafka/KafkaHelper.java
@@ -37,10 +37,7 @@ static Map<String, String> envVars() {
         Map<String, String> envVars = new HashMap<>();
         envVars.put("CLUSTER_ID", DEFAULT_CLUSTER_ID);
 
-        envVars.put(
-            "KAFKA_LISTENERS",
-            "PLAINTEXT://0.0.0.0:" + KAFKA_PORT + ",BROKER://0.0.0.0:9093,CONTROLLER://0.0.0.0:9094"
-        );
+        envVars.put("KAFKA_LISTENERS", "PLAINTEXT://:" + KAFKA_PORT + ",BROKER://:9093,CONTROLLER://:9094");
         envVars.put(
             "KAFKA_LISTENER_SECURITY_PROTOCOL_MAP",
             "BROKER:PLAINTEXT,PLAINTEXT:PLAINTEXT,CONTROLLER:PLAINTEXT"

diff --git a/modules/kafka/src/test/java/org/testcontainers/kafka/KafkaContainerTest.java b/modules/kafka/src/test/java/org/testcontainers/kafka/KafkaContainerTest.java
@@ -13,7 +13,7 @@ public class KafkaContainerTest extends AbstractKafka {
     @Test
     public void testUsage() throws Exception {
         try ( // constructorWithVersion {
-            KafkaContainer kafka = new KafkaContainer("apache/kafka-native:3.8.0")
+            KafkaContainer kafka = new KafkaContainer("apache/kafka-native:3.9.0")
             // }
         ) {
             kafka.start();