# Functions
NewKafkaProviderFlag initializes the -kafka-provider flag and returns a pointer to the parsed value.
RequireKafka starts a Kafka-compatible API in a docker container, serving on port 9092, and creates the requested topic.
# Constants
No description provided by the author
No description provided by the author
# Structs
KafkaContainer is a reference to the docker kafka running Kafka (or RedPanda).
KafkaOpts configures options for starting the test Kafka API.
# Type aliases
No description provided by the author