kafka

Documentation

Index

• func WithClusterID(clusterID string) testcontainers.CustomizeRequestOption
• type KafkaContainer
  • func RunContainer(ctx context.Context, opts ...testcontainers.ContainerCustomizer) (*KafkaContainer, error)
  • func (kc *KafkaContainer) Brokers(ctx context.Context) ([]string, error)

Functions

func WithClusterID

func WithClusterID(clusterID string) testcontainers.CustomizeRequestOption

Types

type KafkaContainer

type KafkaContainer struct {
	testcontainers.Container
	ClusterID string
}

KafkaContainer represents the Kafka container type used in the module

func RunContainer

func RunContainer(ctx context.Context, opts ...testcontainers.ContainerCustomizer) (*KafkaContainer, error)

RunContainer creates an instance of the Kafka container type

func (*KafkaContainer) Brokers

func (kc *KafkaContainer) Brokers(ctx context.Context) ([]string, error)

Brokers retrieves the broker connection strings from Kafka with only one entry, defined by the exposed public port.