How to create a Kafka test Container

[wuqunfei]

Could we create a Kafka container like this
with TestContainer(image="confluentinc/cp-kafka:5.4.3") as container: ip = container.get_container_host_ip()

but I don't know how to implement a method like https://www.testcontainers.org/modules/kafka/
kafka.getBootstrapServers()

[ash1425]

Kafka container from confluent needs some more configurations before it can be started. I am working on a PR for kafka container. Meanwhile you can look at sample implementation at https://github.com/SrinivasanTarget/python_flask_app/blob/main/test/kafka.py.
This sample and my PR is highly inspired by Kafka testcontainer module in java.

[manojhans]

@wuqunfei you can create kafka container using DockerCompose with specific port, here is the example: https://github.com/manojhans/python_testcontainers_kafka