integration

Documentation

Index

• type KafkaCluster
  • func StartKafkaCluster(ctx context.Context, numBrokers int, options map[int][]gnomock.Option) (*KafkaCluster, error)
  • func (kc *KafkaCluster) Cleanup(ctx context.Context) error
  • func (kc *KafkaCluster) CreateTopicWithTraffic(topicName string, replicaAssignments [][]int) error
  • func (kc *KafkaCluster) GetBootstrapServer() string
  • func (kc *KafkaCluster) GetClient() *kafka.Client
  • func (kc *KafkaCluster) GetNetworkID() string

Types

type KafkaCluster

type KafkaCluster struct {
	// contains filtered or unexported fields
}

func StartKafkaCluster

func StartKafkaCluster(ctx context.Context, numBrokers int, options map[int][]gnomock.Option) (*KafkaCluster, error)

StartKafkaCluster starts a Kafka cluster with the prescribed number of brokers and returns it.

Note that there can be containers and networks that need to be cleaned up even if this returns an error.

func (*KafkaCluster) Cleanup

func (kc *KafkaCluster) Cleanup(ctx context.Context) error

func (*KafkaCluster) CreateTopicWithTraffic

func (kc *KafkaCluster) CreateTopicWithTraffic(topicName string, replicaAssignments [][]int) error

func (*KafkaCluster) GetBootstrapServer

func (kc *KafkaCluster) GetBootstrapServer() string

func (*KafkaCluster) GetClient

func (kc *KafkaCluster) GetClient() *kafka.Client

func (*KafkaCluster) GetNetworkID

func (kc *KafkaCluster) GetNetworkID() string