[e2e] Try to fix e2e tests timeout by updating kafka docker version (#…

…4637)
apache · Dec 4, 2024 · 05e3e62 · 05e3e62
1 parent 2e2a214
commit 05e3e62
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/paimon-e2e-tests/src/test/java/org/apache/paimon/tests/E2eTestBase.java b/paimon-e2e-tests/src/test/java/org/apache/paimon/tests/E2eTestBase.java
@@ -111,7 +111,8 @@ public void before() throws Exception {
             for (String s : kafkaServices) {
                 environment.withLogConsumer(s + "-1", new Slf4jLogConsumer(LOG));
             }
-            environment.waitingFor("kafka-1", buildWaitStrategy(".*Recorded new controller.*", 2));
+            environment.waitingFor(
+                    "kafka-1", buildWaitStrategy(".*Recorded new ZK controller.*", 2));
         }
         if (withHive) {
             List<String> hiveServices =

diff --git a/paimon-e2e-tests/src/test/resources-filtered/docker-compose.yaml b/paimon-e2e-tests/src/test/resources-filtered/docker-compose.yaml
@@ -77,7 +77,7 @@ services:
   # ----------------------------------------
 
   zookeeper:
-    image: confluentinc/cp-zookeeper:7.0.1
+    image: confluentinc/cp-zookeeper:7.8.0
     networks:
       testnetwork:
         aliases:
@@ -89,7 +89,7 @@ services:
       - "2181"
 
   kafka:
-    image: confluentinc/cp-kafka:7.0.1
+    image: confluentinc/cp-kafka:7.8.0
     networks:
       testnetwork:
         aliases: