Allow for customization of the Kafka container image

[gunnarmorling]

Hey, great work with Testcontainers! The Debezium community is currently working on Testcontainers support for Debezium, aiming to simplify integration tests of CDC pipelines.

We're currently using the existing Kafka TC container; we'd like to be able to use our own Kafka image for that purpose.

[bsideup]

Thank you for the feedback!

Do you want to use a re-published Confluent Platform image or a custom Kafka one?
In our Kafka container we rely on some scripts from Confluent Platform (as the only semi-official source of Kafka Docker images, unfortunately), but we could also extract some common parts I guess.

[gunnarmorling]

Do you want to use a re-published Confluent Platform image or a custom Kafka one?

We'd like to use the Kafka image built by the Debezium community. What are these scripts exactly about?

[bsideup]

See

testcontainers-java/modules/kafka/src/main/java/org/testcontainers/containers/KafkaContainer.java

Line 108 in 2e9adb9

protected void containerIsStarting(InspectContainerResponse containerInfo, boolean reused) {

and

testcontainers-java/modules/kafka/src/main/java/org/testcontainers/containers/KafkaContainer.java

Line 145 in 2e9adb9

private String startZookeeper() {

[stale]

This issue has been automatically marked as stale because it has not had recent activity. It will be closed if no further activity occurs. If you believe this is a mistake, please reply to this comment to keep it open. If there isn't one already, a PR to fix or at least reproduce the problem in a test case will always help us get back on track to tackle this.

[stale]

This issue has been automatically closed due to inactivity. We apologise if this is still an active problem for you, and would ask you to re-open the issue if this is the case.