kafka

type ConsumerCallback func(data []byte)

type ConsumerConfig struct {
	Brokers  []string        `json:"brokers"yaml:"brokers"`    //Kafka地址
	Group    string          `json:"group"yaml:"group"`        //Kafka消费者组
	Topics   []string        `json:"topics"yaml:"topics"`      //消费者需要消费的Topic
	Assignor string          `json:"assignor" yaml:"assignor"` //Kafka消费者组分配策略---随机，轮询，严格
	Oldest   bool            `json:"oldest" yaml:"oldest"`     //Kafka消费者是否需要从topic开始的offset开始消费
	Verbose  bool            `json:"verbose" yaml:"verbose"`   // sarama的日志开关
	Consumer sarama.Consumer `json:"-" yaml:"-"`
}

type ProducerConfig struct {
	Brokers      []string            `json:"brokers" yaml:"brokers"` //Kafka地址
	Topics       []string            `json:"topics" yaml:"topics"`   //消费者需要消费的Topic
	Success      bool                `json:"success" yaml:"success"`
	RequiredAcks int16               `json:"requiredAcks" yaml:"requiredAcks"`
	Producer     sarama.SyncProducer `json:"-" yaml:"-"`
}