- class KafkaContainer(image: str = 'confluentinc/cp-kafka:7.6.0', port: int = 9093, **kwargs)¶
Kafka container.
Example
>>> from testcontainers.kafka import KafkaContainer >>> with KafkaContainer() as kafka: ... connection = kafka.get_bootstrap_server() # Using KRaft protocol >>> with KafkaContainer().with_kraft() as kafka: ... connection = kafka.get_bootstrap_server()