queue

type Consumer interface {
	Run() error
}

type ConsumerCfg struct {
	TopicList []string
	GrouponId string
	Addr      []string
}

type KafKaQueue struct {
	Addr     []string
	Producer sarama.SyncProducer
}

type SimpleConsumer struct {
	Cfg  *ConsumerCfg
	Work Worker
}

type Worker func(msg *protocol.EventData) error