You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
[info] - must no messages should be lost when two consumers consume from one topic and two partitions and one consumer aborts mid-stream *** FAILED *** (1 minute, 54 seconds)
[info] java.util.concurrent.TimeoutException: Future timed out after [100 seconds]
[info] at scala.concurrent.impl.Promise$DefaultPromise.tryAwait0(Promise.scala:248)
[info] at scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:261)
[info] at scala.concurrent.Await$.$anonfun$result$1(package.scala:201)
[info] at scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:62)
[info] at scala.concurrent.Await$.result(package.scala:124)
[info] at akka.kafka.scaladsl.RebalanceExtSpec.$anonfun$new$3(RebalanceExtSpec.scala:306)
The text was updated successfully, but these errors were encountered:
https://github.com/akka/alpakka-kafka/actions/runs/6624612670/job/17994126408?pr=1686#step:6:1850
The text was updated successfully, but these errors were encountered: