CreateKafkaTopics interacts with the Kafka broker to create topics, deleting them when the test completes.

DestroyKafka destroys the Redpanda Docker container.

InitKafka initialises Kafka configuration, and returns a pair of functions for provisioning and destroying a Kafka cluster.

KafkaCommonConfig returns a kafka.CommonConfig suitable for connecting to the configured Kafka broker in tests.

NewKafkaManager returns a new kafka.Manager for the configured broker.

ProvisionKafka starts a single node Redpanda broker running as a local Docker container, and configures Kafka clients to communicate with the broker by forwarding the necessary port(s).

RandomSuffix generates a lowercase alphabetic 8 character random string.

SuffixTopics suffixes the received topics with a random suffix.

TestLogger creates a new zap.Logger meant to be used for tests.

DestroyInfraFunc is a function returned by Init* functions for destroying infrastructure.

ProvisionInfraFunc is a function returned by Init* functions for provisioning infrastructure.