I have a simple test which produces messages to the embedded Kafka ( withEmbeddedKafkaLike) and then uses a probe. request and expectMessages. The test though doesn’t pass without the akka.test.single-expect-default being set to a value higher or equal to 5 seconds. I’ve tried every possible producer and consumer settings but without any success, any value less than 5 seconds just causes a timeout exception: `assertion failed: timeout (4 seconds) during expectMsg while waiting for OnNext(1)
java.lang.AssertionError: assertion failed: timeout (4 seconds) during expectMsg while waiting for OnNext(1)
It’s actually quite annoying as it slows done my whole test suite quite significantly.
Any idea how to speed it up ?