Module confluent 

Available on crate feature kafka only.

Test container based on Confluent Kafka Image

Structs

Kafka

Module to work with Apache Kafka inside of tests.

Constants

DEFAULT_BROKER_ID

The default broker id.

DEFAULT_CLUSTER_ID

The default cluster id to use.

DEFAULT_INTERNAL_TOPIC_RF

The default Replication Factor to use.

KAFKA_PORT

Port that the Kafka part of the container has internally Can be rebound externally via testcontainers::core::ImageExt::with_mapped_port

ZOOKEEPER_PORT

Port that the Zookeeper part of the container has internally Can be rebound externally via testcontainers::core::ImageExt::with_mapped_port