I’m trying to run any unit test from the alpakka repository that doesn’t use a probe (https://github.com/akka/alpakka-kafka/blob/master/tests/src/test/scala/docs/scaladsl/ConsumerExample.scala) Await.result or any command to get a result from a Consumer always times out. I’ve tried increasing the timeout but it still does for all the unit test that I’ve tried.
I didn’t see this before now, is this still a problem for you?
Thanks for the check. I used testcontainers instead with a kafka consumer. I will post an update if ever I re-explore these unit tests.