kafka

type Composed struct {
	Kafka     *Container
	Zookeeper *tczk.Container
	Network   testcontainers.Network
}

type Consumer struct {
	MessageChan chan *sarama.ConsumerMessage
	// contains filtered or unexported fields
}

type ConsumerOptions struct {
	Brokers []string
	Group   string
	Version string
	Topics  []string
}

type Container struct {
	tc.ContainerConfig
	Container testcontainers.Container
	Host      string
	Port      int
	Brokers   []string
	Listeners []string
	Version   string
}

type Options struct {
	tc.ContainerOptions
	LogLevel          string
	KafkaImageTag     string
	ZookeeperImageTag string
}

type Producer struct {
	DataCollector     sarama.SyncProducer
	AccessLogProducer sarama.AsyncProducer
}

type ProducerOptions struct {
	Brokers []string
	Group   string
	Version string
	Topics  []string
}