search

akka / alpakka-kafka

Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
https://doc.akka.io/libraries/alpakka-kafka/current/
Other
1.42k stars 386 forks source link

Failed IntegrationSpec must signal rebalance events to actor #832

Closed 2m closed 5 years ago

2m commented 5 years ago 
[info] - must signal rebalance events to actor *** FAILED *** (37 seconds, 646 milliseconds)
[info]   A timeout occurred waiting for a future to complete. Queried 61 times, sleeping 500000000 nanoseconds between each query. (IntegrationSpec.scala:120)
[info]   org.scalatest.concurrent.Futures$FutureConcept$$anon$1:
[info]   at org.scalatest.concurrent.Futures$FutureConcept.tryTryAgain$1(Futures.scala:538)
[info]   at org.scalatest.concurrent.Futures$FutureConcept.futureValueImpl(Futures.scala:550)
[info]   at org.scalatest.concurrent.Futures$FutureConcept.futureValueImpl$(Futures.scala:479)
[info]   at org.scalatest.concurrent.ScalaFutures$$anon$1.futureValueImpl(ScalaFutures.scala:275)
[info]   at org.scalatest.concurrent.Futures$FutureConcept.futureValue(Futures.scala:476)
[info]   at org.scalatest.concurrent.Futures$FutureConcept.futureValue$(Futures.scala:475)
[info]   at org.scalatest.concurrent.ScalaFutures$$anon$1.futureValue(ScalaFutures.scala:275)
[info]   at akka.kafka.scaladsl.IntegrationSpec.$anonfun$new$6(IntegrationSpec.scala:120)
[info]   at akka.stream.testkit.scaladsl.StreamTestKit$.assertAllStagesStopped(StreamTestKit.scala:32)
[info]   at akka.kafka.scaladsl.IntegrationSpec.$anonfun$new$5(IntegrationSpec.scala:52)

https://travis-ci.org/akka/alpakka-kafka/jobs/547197965

ennru commented 5 years ago

Not all messages are received for some reason https://travis-ci.org/akka/alpakka-kafka/jobs/580201215#L890