failed: RebalanceExtSpec #1688
Description
[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)