kafka

type Config struct {
	BrokerList   []string
	ConsumerConf *ConsumerConf
	ProducerConf *ProducerConf
}

type ConsumerConf struct {
	Topics        []string
	ConsumerGroup string
	Partition     int32
	Offset        int64
}

type Entity struct {
	ConnName     string
	SaramaClient sarama.Client
	SaramaConfig *sarama.Config
	ErrChan      chan error
	MsgChan      chan string
}

type ProducerConf struct {
	Topic     string
	Partition int32
}