kafka

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

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

type ContainerConnectionConfig struct {
	tc.ContainerConfig
	Brokers      []string
	KafkaVersion string
}

type ContainerOptions struct {
	tc.ContainerOptions
	StartZookeeper bool
}

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

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