consumer

type CommonMessage struct {
	Database string                   // 数据库或schema
	Table    string                   // 表名
	PkNames  []string                 // 主键名列表
	IsDdl    bool                     // 是否是DDL操作
	Type     string                   // 类型：INSERT/UPDATE/DELETE
	Es       int64                    // binlog执行时间，执行耗时
	Ts       int64                    // DML构建时间戳，同步时间
	SQL      string                   // 执行的SQL，DML SQL为空
	Data     []map[string]interface{} // 数据列表
	Old      []map[string]interface{} // 旧数据列表，用于更新，size和data的size一一对应
}

type ConsumeTopic struct {
	//一个消费者组里包含几个消费者
	ConsumeNum int
	//消费者组监听的主题
	Topics []string
	//回调的Handler, 需要调用者自己实现
	Callback sarama.ConsumerGroupHandler
}

type Message struct {
	// serialVersionUID uint64
	ID         int64
	Entries    []*protocal_message.Entry
	Raw        bool
	RawEntries [][]byte
}