Dbus中UMS统一消息格式

无论是增量、全量还是日志，最终输出到结果kafka中的消息都是我们约定的统一消息格式,称为UMS(unified message schema)格式。如下图所示：

• Protocol
  • 数据的类型，被UMS的版本号
• schema
  • namespace 由：类型. 数据源名.schema名 .表名.表版本号. 分库号 .分表号 组成，能够描述所有表。
    • 例如：mysql.db1.schema1.testtable.5.0.0
  • fields是字段名描述
    • ums_id_ 消息的唯一id，保证消息是唯一的
    • ums_ts_ canal捕获事件的时间戳；
    • ums_op_ 表明数据的类型是I (insert)，U (update)，B (before Update)，D(delete)
    • ums_uid_ 数据流水号，唯一值
• payload是指具体的数据
  • 一个json包里面可以包含1条至多条数据，提高数据的有效载荷。