consumers

type Consumer struct {
	Name     string
	Config   *ConsumerConfig
	Consumer *cluster.Consumer
	// contains filtered or unexported fields
}

type ConsumerConfig struct {
	Name     string
	User     string
	Password string
	Broker   []string
	GroupId  string
	Topic    []string
}

type ConsumerGroup struct {
	// contains filtered or unexported fields
}

type DtsData struct {
	//数据源
	Consumer string `json:"consumer"`
	//表名
	Table string `json:"table"`
	//事件时间
	Datetime string `json:"datetime"`
	//字段信息
	Data []DtsValue `json:"data"`
	//变更字段列表
	Fields []string `json:"fields"`
	//数据库事件
	Operation string `json:"operation"`
}

type DtsValue struct {
	Name      string `json:"name"`
	BeforeVal string `json:"before"`
	AfterVal  string `json:"after"`
}

type Group map[string]Consumer