Verwendung von Testcontainern mit einem anderen Kafka-Docker-Image in JUnit5 ⇐ Java

[Anonymous]

Ich schreibe einige Integrationstests mit JUnit5 und Testcontainern. Zum Testen meiner Kafka-Funktionalität verwende ich das folgende Bild:

Code: Select all

kafkaContainer = new KafkaContainer(
DockerImageName.parse("confluentinc/cp-kafka:latest"));
kafkaContainer.start();

Aber in der Produktion habe ich das Bild bitnami/kafka:3.9.0:

Code: Select all

new KafkaContainer(
DockerImageName.parse("bitnami/kafka:3.9.0")
.asCompatibleSubstituteFor("confluentinc/cp-kafka:latest")

Wenn ich den obigen Code ändere, um dieses Bild zu verwenden, erhalte ich

Code: Select all

2025-01-01 INFO  - tc.bitnami/kafka:3.9.0 : Creating container for image: bitnami/kafka:3.9.0
2025-01-01 INFO  - tc.bitnami/kafka:3.9.0 : Container bitnami/kafka:3.9.0 is starting: 341fef08d0f81708bf830e0b24e33e8b5af9f89b553fa5a9abdcd28a67980174
2025-01-17 ERROR - tc.bitnami/kafka:3.9.0 : Could not start container

java.lang.IllegalStateException: Wait strategy failed. Container exited with code 127
at org.testcontainers.containers.GenericContainer.tryStart(GenericContainer.java:523)
[..]
Caused by: org.testcontainers.containers.ContainerLaunchException: Timed out waiting for log output matching '.*\[KafkaServer id=\d+\] started.*'
at org.testcontainers.containers.wait.strategy.LogMessageWaitStrategy.waitUntilReady(LogMessageWaitStrategy.java:47)
[..]

Wie kann ich meine Testcontainer am besten dazu bringen, dieses Bitnami-Kafka-Image zu verwenden?