功能
控制增量同步时delete 和update 是否允许primary key 的值为空。
默认值为0,即如果delete 和update 时primary key 的值为空则报错;
值为1时,
增量同步delete和update允许primary key的值为空,
这时kafka consumer
会正常进行同步,但是不保证同步结果与原数据库完全一致。
举例:
update t1 set A=2 where primarykey=1;
update t1 set A=2 where A=1;
{
"table":"BDTEST.T1",
"op_type":"U",
"op_ts":"2022-01-16 09:32:33.705303",
"current_ts":"2022-01-16T17:32:36.839000",
"pos":"00000000030000002612",
"primary_keys":{"A"},
"before":{
"A":1
}
"after":{
"A":2
}
}