Repository navigation
How to create a Kafka test Container #121
Description
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()
Activity
ash1425 commentedon Jan 5, 2021
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 commentedon Feb 17, 2021
@wuqunfei you can create kafka container using
DockerComposewith specific port, here is the example: https://github.com/manojhans/python_testcontainers_kafka