kafka

type Config struct {
	Topic                string
	Zookeepers           []string
	ConsumerGroupName    string
	ConsumerBuffer       int
	MaxErrors            int
	MaxRetry             int
	BatchSize            int
	FlushInterval        int
	ConsumerTransactions *uint64
	ProducerTransactions *uint64
}

type Kafka struct {
	// Config
	Conf Config

	Brokers []string

	// Kafka stuff
	Producer sarama.AsyncProducer
	Consumer *consumergroup.ConsumerGroup

	ProducerChan chan *sarama.ProducerMessage
	TransferChan chan *sarama.ProducerMessage

	// other stuff
	WaitGroup *sync.WaitGroup
	Shutdown  chan struct{}
	// contains filtered or unexported fields
}