scalatest-embedded-kafka
scalatest-embedded-kafka copied to clipboard
consumeFirstStringMessageFrom fails too slowly when Kafka is not available
request.max.timeout.ms
is set too high, and should be probably lowered for the underlying consumer (even if the problem only appears in a non-likely use case, when trying to consume from a non-running kafka).