(flink-connector-kafka) branch v4.0 updated: [FLINK-39121][tests] Retry kafka containers startup

[martijnvisser]

This is an automated email from the ASF dual-hosted git repository.

MartijnVisser pushed a commit to branch v4.0
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git


The following commit(s) were added to refs/heads/v4.0 by this push:
     new f8475754 [FLINK-39121][tests] Retry kafka containers startup
f8475754 is described below

commit f8475754720f245b0d37480321506698a12198e1
Author: Efrat Levitan <elevi...@confluent.io>
AuthorDate: Thu Jun 4 19:22:08 2026 +0200

    [FLINK-39121][tests] Retry kafka containers startup
    
    (cherry picked from commit d67857014bc288a03849dc2cc9989c57bd6a2ec1)
---
 .../java/org/apache/flink/connector/kafka/testutils/KafkaUtil.java    | 3 ++-
 .../apache/flink/connector/kafka/testutils/TwoKafkaContainers.java    | 4 ++--
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaUtil.java
 
b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaUtil.java
index 78b344b6..97dd05ed 100644
--- 
a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaUtil.java
+++ 
b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaUtil.java
@@ -75,7 +75,8 @@ public class KafkaUtil {
                         "KAFKA_TRANSACTION_MAX_TIMEOUT_MS",
                         String.valueOf(Duration.ofHours(2).toMillis()))
                 .withEnv("KAFKA_LOG4J_TOOLS_ROOT_LOGLEVEL", logLevel)
-                .withLogConsumer(logConsumer);
+                .withLogConsumer(logConsumer)
+                .withStartupAttempts(3);
     }
 
     private static String inferLogLevel(Logger logger) {
diff --git 
a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/TwoKafkaContainers.java
 
b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/TwoKafkaContainers.java
index 6c5036a9..2eb08dc5 100644
--- 
a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/TwoKafkaContainers.java
+++ 
b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/TwoKafkaContainers.java
@@ -29,8 +29,8 @@ public class TwoKafkaContainers extends 
GenericContainer<TwoKafkaContainers> {
 
     public TwoKafkaContainers() {
         DockerImageName dockerImageName = 
DockerImageName.parse(DockerImageVersions.KAFKA);
-        this.kafka0 = new KafkaContainer(dockerImageName);
-        this.kafka1 = new KafkaContainer(dockerImageName);
+        this.kafka0 = new 
KafkaContainer(dockerImageName).withStartupAttempts(3);
+        this.kafka1 = new 
KafkaContainer(dockerImageName).withStartupAttempts(3);
     }
 
     @Override