Versions in this module Expand all Collapse all v1 v1.0.0 Nov 22, 2022 Changes in this version + const DefaultContainerShutdownTimeout + const DefaultContainerStartTimeout + const DefaultKafkaClientPort + const DefaultKafkaImage + const DefaultNetworkCreateTimeout + const DefaultNetworkPrefix + const DefaultNetworkShutdownTimeout + const DefaultTLS + const DefaultZookeeperImage + var DefaultKafkaWaitStrategy = wait.ForLog("Initialized broker") + var DefaultLogger = testcontainers.Logger + var DefaultZookeeperWaitStrategy = wait.ForLog("binding to port") + type KafkaCluster struct + func NewKafkaCluster(ctx context.Context, setters ...Option) (*KafkaCluster, error) + func NewKafkaClusterWithOptions(ctx context.Context, origOptions *Options) (*KafkaCluster, error) + func (kc *KafkaCluster) ClientTLSConfig() *tls.Config + func (kc *KafkaCluster) GetKafkaHost(ctx context.Context) (string, error) + func (kc *KafkaCluster) GetKafkaHostAndPort(ctx context.Context) (string, error) + func (kc *KafkaCluster) StopCluster(ctx context.Context) + type Option func(*Options) + func WithContainerShutdownTimeout(timeout time.Duration) Option + func WithContainerStartTimeout(timeout time.Duration) Option + func WithKafkaClientPort(port int) Option + func WithKafkaImage(image string) Option + func WithKafkaWaitStrategy(strategy wait.Strategy) Option + func WithLogger(logger testcontainers.Logging) Option + func WithNetworkCreateTimeout(timeout time.Duration) Option + func WithNetworkPrefix(prefix string) Option + func WithNetworkShutdownTimeout(timeout time.Duration) Option + func WithTLS(tls bool) Option + func WithZookeeperImage(image string) Option + func WithZookeeperWaitStrategy(strategy wait.Strategy) Option + type Options struct + ContainerShutdownTimeout time.Duration + ContainerStartTimeout time.Duration + KafkaClientPort int + KafkaImage string + KafkaWaitStrategy wait.Strategy + Logger testcontainers.Logging + NetworkCreateTimeout time.Duration + NetworkPrefix string + NetworkShutdownTimeout time.Duration + TLS bool + ZookeeperImage string + ZookeeperWaitStrategy wait.Strategy