特别说明

最近更新时间: 2019-11-12 02:57:05

MySQL数据库采集的投递目标topic,字段必须严格按照以下格式创建,创建方式详见“新建topic”下”设计态-新建topic”章节

{
"table": "TCLOUD.T_OGG2", //库名.表名
"op_type": "U", //操作类型 U更新 D删除 I插入
"current_ts": "2018-05-31T14:49:01.709000", //【处理时间】
"pos": "00000000000000003770", //偏移量
"before": { //object类型,操作前的字段
"ID": 1, //业务字段
"AGE": 20,
"IDD": "1"
},
"after": { // object类型,操作后的字段
"ID": 1,
"AGE": 1,
"IDD": "1"
}
}

Oracle数据库采集的投递目标topic,字段必须严格按照以下格式创建,创建方式详见“新建topic”下”设计态-新建topic”章节

{
"table": "TCLOUD.T_OGG2", //库名.表名
"op_type": "U", //操作类型 U更新 D删除 I插入
"op_ts": "2018-05-31 14:48:55.630340", //操作时间 
"current_ts": "2018-05-31T14:49:01.709000", //【处理时间】
"pos": "00000000000000003770", //偏移量
"before": { //object类型,操作前的字段
"ID": 1, //业务字段
"AGE": 20,
"IDD": "1"
},
"after": { // object类型,操作后的字段
"ID": 1,
"AGE": 1,
"IDD": "1"
}
}