Versions in this module Expand all Collapse all v1 v1.1.0 Mar 13, 2024 v1.0.0 Mar 6, 2024 Changes in this version + type KafkaCluster struct + 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
Go to main page