Skip to content

Commit ca29115

Browse files
committed
incr startup timeout of Connect containers
1 parent afa3d70 commit ca29115

File tree

2 files changed

+7
-2
lines changed

2 files changed

+7
-2
lines changed

src/integrationTest/java/com/solace/connector/kafka/connect/source/it/util/testcontainers/BitnamiKafkaConnectContainer.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
import org.testcontainers.utility.DockerImageName;
1212

1313
import java.nio.charset.StandardCharsets;
14+
import java.time.Duration;
1415
import java.util.Comparator;
1516

1617
public class BitnamiKafkaConnectContainer extends GenericContainer<BitnamiKafkaConnectContainer> {
@@ -47,7 +48,8 @@ public BitnamiKafkaConnectContainer(DockerImageName dockerImageName) {
4748
BROKER_LISTENER_NAME + "://:" + BROKER_LISTENER_PORT, BOOTSTRAP_LISTENER_NAME + "://:" + BOOTSTRAP_LISTENER_PORT));
4849
withClasspathResourceMapping(Tools.getUnzippedConnectorDirName() + "/lib",
4950
"/opt/bitnami/kafka/jars/pubsubplus-connector-kafka", BindMode.READ_ONLY);
50-
waitingFor(Wait.forLogMessage(".*Finished starting connectors and tasks.*", 1));
51+
waitingFor(Wait.forLogMessage(".*Finished starting connectors and tasks.*", 1)
52+
.withStartupTimeout(Duration.ofMinutes(10)));
5153
}
5254

5355
@Override

src/integrationTest/java/com/solace/connector/kafka/connect/source/it/util/testcontainers/ConfluentKafkaConnectContainer.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,8 @@
77
import org.testcontainers.containers.wait.strategy.Wait;
88
import org.testcontainers.utility.DockerImageName;
99

10+
import java.time.Duration;
11+
1012
import static org.hamcrest.MatcherAssert.assertThat;
1113
import static org.hamcrest.Matchers.greaterThanOrEqualTo;
1214
import static org.junit.jupiter.api.Assertions.assertEquals;
@@ -52,7 +54,8 @@ public ConfluentKafkaConnectContainer(DockerImageName dockerImageName,
5254
withEnv("CONNECT_PLUGIN_PATH", "/usr/share/java,/etc/kafka-connect/jars");
5355
withClasspathResourceMapping(Tools.getUnzippedConnectorDirName() + "/lib",
5456
"/etc/kafka-connect/jars", BindMode.READ_ONLY);
55-
waitingFor( Wait.forLogMessage(".*Kafka Connect started.*", 1) );
57+
waitingFor(Wait.forLogMessage(".*Kafka Connect started.*", 1)
58+
.withStartupTimeout(Duration.ofMinutes(10)));
5659
}
5760

5861
public String getConnectUrl() {

0 commit comments

Comments
 (0)