testutil

Documentation

Index

• type KafkaTestEnv
  • func NewKafkaTestEnv(ctx context.Context, clusterID string, topics []string) (*KafkaTestEnv, error)
  • func (k *KafkaTestEnv) Close(ctx context.Context) error
  • func (k *KafkaTestEnv) CreateTopics(ctx context.Context, topics ...string) error

Types

type KafkaTestEnv

type KafkaTestEnv struct {
	ClusterID   string
	Brokers     []string
	Container   *kafka.KafkaContainer
	Producer    *kgo.Client
	Consumer    *kgo.Client
	AdminClient *kadm.Client
}

func NewKafkaTestEnv

func NewKafkaTestEnv(ctx context.Context, clusterID string, topics []string) (*KafkaTestEnv, error)

func (*KafkaTestEnv) Close

func (k *KafkaTestEnv) Close(ctx context.Context) error

func (*KafkaTestEnv) CreateTopics

func (k *KafkaTestEnv) CreateTopics(ctx context.Context, topics ...string) error