kafka

type KafkaInput struct {
	Addrs  []string `json:"addrs" yaml:"addr"` //如果定义了group,则addrs是zookeeper的地址(2181)，否则的话是kafka的地址(9092)
	Topics []string `json:"topics" yaml:"topics"`
	Group  string   `json:"group" yaml:"group"`
	Offset int64    `json:"offset" yaml:"offset"`

	Message chan []byte //从这个管道中读取数据
}

type Producer struct {
	Addrs    []string    `json:"addrs" yaml:"addrs"`
	Topic    string      `json:"topic" yaml:"topic"`
	MaxProcs int         `json:"max_procs" yaml:"max_procs"` //最大并发写协程, 由于并发写入topic,写入顺序不可控,想要严格数序的话,maxThreads = 1即可
	Message  chan []byte `json:"-" yaml:"-"`                 //将数据写入这个管道中
	// contains filtered or unexported fields
}