databus

type ConsumerDeal interface {
	//数据处理的实现
	DealMessage(data []byte, topic string, partition int32, offset int64, groupid string) error

	//消费组增加消费者的消息通知
	Setup(topicAndPartitions map[string][]int32, memberId string, generationId int32)

	//消费组中消费者退出的消息通知
	Cleanup(topicAndPartitions map[string][]int32, memberId string, generationId int32)
}

type ConsumerEvent interface {
	//启动轮询消费数据
	Start() error

	//关闭消费者，必须调用
	Close()
}

type ConsumerParam struct {
	Address   []string
	GroupId   string
	Topic     string
	KafkaVer  string
	Dealhanle ConsumerDeal
}

type ProducerEvent interface {
	//发送消息接口
	SendMessage(data []byte, key string) error

	//关闭生产者
	Close()
}

type ProducerParam struct {
	Address     []string
	Topic       string
	IsAck       bool
	KafkaVer    string
	Partitioner uint32
}