This is an automated email from the ASF dual-hosted git repository.
pjfanning pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-connectors-kafka.git
The following commit(s) were added to refs/heads/main by this push:
new 10fffa1d increase timeout for kafka docker container startup (#558)
10fffa1d is described below
commit 10fffa1d504b9ce05e4ec48cc8c2a97093ff31a9
Author: PJ Fanning <[email protected]>
AuthorDate: Wed Jun 17 17:24:07 2026 +0100
increase timeout for kafka docker container startup (#558)
---
.../pekko/kafka/testkit/internal/PekkoConnectorsKafkaContainer.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git
a/testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/PekkoConnectorsKafkaContainer.java
b/testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/PekkoConnectorsKafkaContainer.java
index f20ee356..65ddfaf9 100644
---
a/testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/PekkoConnectorsKafkaContainer.java
+++
b/testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/PekkoConnectorsKafkaContainer.java
@@ -17,6 +17,7 @@ package org.apache.pekko.kafka.testkit.internal;
import com.github.dockerjava.api.command.InspectContainerResponse;
import com.github.dockerjava.api.model.ContainerNetwork;
import java.nio.charset.StandardCharsets;
+import java.time.Duration;
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;
@@ -80,6 +81,9 @@ public class PekkoConnectorsKafkaContainer extends
GenericContainer<PekkoConnect
withExposedPorts(KAFKA_PORT);
+ // The default startup timeout of 1 minute is not enough for Kafka to
start reliably in CI
+ withStartupTimeout(Duration.ofMinutes(3));
+
withBrokerNum(this.brokerNum);
// Use two listeners with different names, it will force Kafka to
communicate with itself via
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
