Kafka TestContainers fails to connect
I have a very simple TestContainers Kafka + Kotlin test that fails because my test code cannot connect to the Kafka instance.
My Class def looks like this:
@Testcontainers
class SimpleKafkaTest {
@Container
val kafkaContainer = KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:6.2.1")).withEmbeddedZookeeper().waitingFor(
Wait.forListeningPort())
Now my test beings as follows:
@Test
internal fun `test kafka`() {
kafkaContainer.start()...