数据复制服务 DRS-Kafka消息格式:JSON-C格式

时间：2024-09-26 16:04:44

数据复制服务 DRS 同步场景操作参考

JSON-C格式与JSON格式类似，区别是对于删除操作，JSON数据放在old上，JSON-C放在data上。对于timestamp类型数据转换成yyyy-mm-dd hh:mm:ss的字符串。

JSON-C定义详情参考表5：

表5 JSON-C参数说明
参数名称	说明
mysqlType	源端表字段名称和类型。
id	DRS内部定义的事件操作的序列号，单调递增。
es	源库产生这一条记录的时间，13位Unix时间戳，单位为毫秒。
ts	写入到目标kafka的时间，13位Unix时间戳，单位为毫秒。
database	数据库名称（Oracle数据库填写schema）。
table	表名。
type	操作类型，比如DELETE，UPDATE，INSERT，DDL。
isDdl	是否是DDL操作。
sql	DDL的SQL语句，在DML操作中，取值为""。
sqlType	源端表字段的jdbc类型。
data	最新的数据，为JSON数组，如果type参数是插入则表示最新插入的数据，如果是更新，则表示更新后的最新数据；如果是删除，则表示被删除的数据。
old	旧数据，如果type参数是更新，则表示更新前的数据；如果是插入，取值为null。
pkNames	主键名称。