You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@pekko.apache.org by "pjfanning (via GitHub)" <gi...@apache.org> on 2026/06/16 18:19:25 UTC
[PR] increase timeout for kafka docker container startup [pekko-connectors-kafka]
pjfanning opened a new pull request, #558:
URL: https://github.com/apache/pekko-connectors-kafka/pull/558
https://github.com/apache/pekko-connectors-kafka/actions/runs/27625225143/job/81687312177
```
[info] docs.scaladsl.SchemaRegistrySerializationSpec *** ABORTED *** (1 minute)
[info] java.lang.RuntimeException: java.util.concurrent.ExecutionException: org.testcontainers.containers.ContainerLaunchException: Container startup failed for image confluentinc/cp-kafka:7.9.2
[info] at org.apache.pekko.kafka.testkit.internal.KafkaContainerCluster.start(KafkaContainerCluster.java:226)
[info] at org.apache.pekko.kafka.testkit.internal.TestcontainersKafka$Spec.startCluster(TestcontainersKafka.scala:104)
[info] at org.apache.pekko.kafka.testkit.internal.TestcontainersKafka$Spec.startCluster$(TestcontainersKafka.scala:28)
[info] at docs.scaladsl.SchemaRegistrySerializationSpec.startCluster(SchemaRegistrySerializationSpec.scala:48)
[info] at org.apache.pekko.kafka.testkit.internal.TestcontainersKafka$Spec.startCluster(TestcontainersKafka.scala:75)
[info] at org.apache.pekko.kafka.testkit.internal.TestcontainersKafka$Spec.startCluster$(TestcontainersKafka.scala:28)
[info] at docs.scaladsl.SchemaRegistrySerializationSpec.startCluster(SchemaRegistrySerializationSpec.scala:48)
[info] at org.apache.pekko.kafka.testkit.scaladsl.TestcontainersKafkaPerClassLike.setUp(TestcontainersKafkaPerClassLike.scala:25)
[info] at org.apache.pekko.kafka.testkit.scaladsl.TestcontainersKafkaPerClassLike.setUp$(TestcontainersKafkaPerClassLike.scala:23)
[info] at docs.scaladsl.SchemaRegistrySerializationSpec.setUp(SchemaRegistrySerializationSpec.scala:48)
[info] at org.apache.pekko.kafka.testkit.internal.TestFrameworkInterface$Scalatest.beforeAll(TestFrameworkInterface.scala:30)
[info] at org.apache.pekko.kafka.testkit.internal.TestFrameworkInterface$Scalatest.beforeAll$(TestFrameworkInterface.scala:26)
[info] at docs.scaladsl.DocsSpecBase.beforeAll(DocsSpecBase.scala:27)
[info] at org.scalatest.BeforeAndAfterAll.liftedTree1$1(BeforeAndAfterAll.scala:212)
[info] at org.scalatest.BeforeAndAfterAll.run(BeforeAndAfterAll.scala:217)
[info] at org.scalatest.BeforeAndAfterAll.run$(BeforeAndAfterAll.scala:135)
[info] at docs.scaladsl.DocsSpecBase.run(DocsSpecBase.scala:27)
[info] at org.scalatest.tools.Framework.org$scalatest$tools$Framework$$runSuite(Framework.scala:321)
[info] at org.scalatest.tools.Framework$ScalaTestTask.execute(Framework.scala:517)
[info] at sbt.ForkMain$Run.lambda$runTest$1(ForkMain.java:414)
[info] at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
[info] at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
[info] at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
[info] at java.base/java.lang.Thread.run(Thread.java:840)
[info] Cause: java.util.concurrent.ExecutionException: org.testcontainers.containers.ContainerLaunchException: Container startup failed for image confluentinc/cp-kafka:7.9.2
[info] at java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396)
[info] at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2096)
[info] at org.apache.pekko.kafka.testkit.internal.KafkaContainerCluster.start(KafkaContainerCluster.java:208)
[info] at org.apache.pekko.kafka.testkit.internal.TestcontainersKafka$Spec.startCluster(TestcontainersKafka.scala:104)
[info] at org.apache.pekko.kafka.testkit.internal.TestcontainersKafka$Spec.startCluster$(TestcontainersKafka.scala:28)
[info] at docs.scaladsl.SchemaRegistrySerializationSpec.startCluster(SchemaRegistrySerializationSpec.scala:48)
[info] at org.apache.pekko.kafka.testkit.internal.TestcontainersKafka$Spec.startCluster(TestcontainersKafka.scala:75)
[info] at org.apache.pekko.kafka.testkit.internal.TestcontainersKafka$Spec.startCluster$(TestcontainersKafka.scala:28)
[info] at docs.scaladsl.SchemaRegistrySerializationSpec.startCluster(SchemaRegistrySerializationSpec.scala:48)
[info] at org.apache.pekko.kafka.testkit.scaladsl.TestcontainersKafkaPerClassLike.setUp(TestcontainersKafkaPerClassLike.scala:25)
[info] at org.apache.pekko.kafka.testkit.scaladsl.TestcontainersKafkaPerClassLike.setUp$(TestcontainersKafkaPerClassLike.scala:23)
[info] at docs.scaladsl.SchemaRegistrySerializationSpec.setUp(SchemaRegistrySerializationSpec.scala:48)
[info] at org.apache.pekko.kafka.testkit.internal.TestFrameworkInterface$Scalatest.beforeAll(TestFrameworkInterface.scala:30)
[info] at org.apache.pekko.kafka.testkit.internal.TestFrameworkInterface$Scalatest.beforeAll$(TestFrameworkInterface.scala:26)
[info] at docs.scaladsl.DocsSpecBase.beforeAll(DocsSpecBase.scala:27)
[info] at org.scalatest.BeforeAndAfterAll.liftedTree1$1(BeforeAndAfterAll.scala:212)
[info] at org.scalatest.BeforeAndAfterAll.run(BeforeAndAfterAll.scala:217)
[info] at org.scalatest.BeforeAndAfterAll.run$(BeforeAndAfterAll.scala:135)
[info] at docs.scaladsl.DocsSpecBase.run(DocsSpecBase.scala:27)
[info] at org.scalatest.tools.Framework.org$scalatest$tools$Framework$$runSuite(Framework.scala:321)
[info] at org.scalatest.tools.Framework$ScalaTestTask.execute(Framework.scala:517)
[info] at sbt.ForkMain$Run.lambda$runTest$1(ForkMain.java:414)
[info] at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
[info] at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
[info] at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
[info] at java.base/java.lang.Thread.run(Thread.java:840)
[info] Cause: org.testcontainers.containers.ContainerLaunchException: Container startup failed for image confluentinc/cp-kafka:7.9.2
[info] at org.testcontainers.containers.GenericContainer.doStart(GenericContainer.java:351)
[info] at org.apache.pekko.kafka.testkit.internal.PekkoConnectorsKafkaContainer.doStart(PekkoConnectorsKafkaContainer.java:194)
[info] at org.testcontainers.containers.GenericContainer.start(GenericContainer.java:322)
[info] at java.base/java.util.concurrent.CompletableFuture$UniRun.tryFire(CompletableFuture.java:787)
[info] at java.base/java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:482)
[info] at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
[info] at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
[info] at java.base/java.lang.Thread.run(Thread.java:840)
[info] Cause: org.rnorth.ducttape.RetryCountExceededException: Retry limit hit with exception
[info] at org.rnorth.ducttape.unreliables.Unreliables.retryUntilSuccess(Unreliables.java:88)
[info] at org.testcontainers.containers.GenericContainer.doStart(GenericContainer.java:336)
[info] at org.apache.pekko.kafka.testkit.internal.PekkoConnectorsKafkaContainer.doStart(PekkoConnectorsKafkaContainer.java:194)
[info] at org.testcontainers.containers.GenericContainer.start(GenericContainer.java:322)
[info] at java.base/java.util.concurrent.CompletableFuture$UniRun.tryFire(CompletableFuture.java:787)
[info] at java.base/java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:482)
[info] at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
[info] at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
[info] at java.base/java.lang.Thread.run(Thread.java:840)
[info] Cause: org.testcontainers.containers.ContainerLaunchException: Could not create/start container
[info] at org.testcontainers.containers.GenericContainer.tryStart(GenericContainer.java:556)
[info] at org.testcontainers.containers.GenericContainer.lambda$doStart$0(GenericContainer.java:346)
[info] at org.rnorth.ducttape.unreliables.Unreliables.retryUntilSuccess(Unreliables.java:81)
[info] at org.testcontainers.containers.GenericContainer.doStart(GenericContainer.java:336)
[info] at org.apache.pekko.kafka.testkit.internal.PekkoConnectorsKafkaContainer.doStart(PekkoConnectorsKafkaContainer.java:194)
[info] at org.testcontainers.containers.GenericContainer.start(GenericContainer.java:322)
[info] at java.base/java.util.concurrent.CompletableFuture$UniRun.tryFire(CompletableFuture.java:787)
[info] at java.base/java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:482)
[info] at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
[info] at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
[info] at java.base/java.lang.Thread.run(Thread.java:840)
[info] Cause: org.testcontainers.containers.ContainerLaunchException: Timed out waiting for container port to open (localhost ports: [32784, 32785] should be listening)
[info] at org.testcontainers.containers.wait.strategy.HostPortWaitStrategy.waitUntilReady(HostPortWaitStrategy.java:112)
[info] at org.testcontainers.containers.wait.strategy.AbstractWaitStrategy.waitUntilReady(AbstractWaitStrategy.java:52)
[info] at org.testcontainers.containers.GenericContainer.waitUntilContainerStarted(GenericContainer.java:909)
[info] at org.testcontainers.containers.GenericContainer.tryStart(GenericContainer.java:492)
[info] at org.testcontainers.containers.GenericContainer.lambda$doStart$0(GenericContainer.java:346)
[info] at org.rnorth.ducttape.unreliables.Unreliables.retryUntilSuccess(Unreliables.java:81)
[info] at org.testcontainers.containers.GenericContainer.doStart(GenericContainer.java:336)
[info] at org.apache.pekko.kafka.testkit.internal.PekkoConnectorsKafkaContainer.doStart(PekkoConnectorsKafkaContainer.java:194)
[info] at org.testcontainers.containers.GenericContainer.start(GenericContainer.java:322)
[info] at java.base/java.util.concurrent.CompletableFuture$UniRun.tryFire(CompletableFuture.java:787)
[info] at java.base/java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:482)
[info] at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
[info] at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
[info] at java.base/java.lang.Thread.run(Thread.java:840)
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscribe@pekko.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@pekko.apache.org
For additional commands, e-mail: notifications-help@pekko.apache.org
Re: [PR] increase timeout for kafka docker container startup [pekko-connectors-kafka]
Posted by "pjfanning (via GitHub)" <gi...@apache.org>.
pjfanning commented on PR #558:
URL: https://github.com/apache/pekko-connectors-kafka/pull/558#issuecomment-4730620108
I'm not sure if the timeout increase will help. The test normally only takes 5-10 seconds to complete. It could be that the docker containers are just not starting up reliably.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscribe@pekko.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@pekko.apache.org
For additional commands, e-mail: notifications-help@pekko.apache.org
Re: [PR] increase timeout for kafka docker container startup [pekko-connectors-kafka]
Posted by "pjfanning (via GitHub)" <gi...@apache.org>.
pjfanning merged PR #558:
URL: https://github.com/apache/pekko-connectors-kafka/pull/558
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscribe@pekko.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@pekko.apache.org
For additional commands, e-mail: notifications-help@pekko.apache.org