case-sensitive = true
enable-old-value = true
force-replicate = true
[filter]
rules = [‘dp_test.*a_tt’,‘dp_test.a_a_n613b’,‘dp_test.a_a_n_613a’]
[mounter]
worker-num=16
[sink]
protocol = “default”
[cyclic-replication]
enable = false
replica-id = 1
filter-replica-ids = [2,3]
sync-ddl = true
目的地端是kafka 我们本地自测的时候大部分情况 一条record的key和value都是同一张表的信息
我们根据kafka record的key 解析key来确定表明，目前kafka record的可以包含了两张表的表明 导致把不同表的数据当作 一张表的数据进行处理了 然后还有一个问题 value 的值
D{{“u”:{“AccountAttr”:{ 还有DY{“u”:{“AccountAttr”:{ 这种 想问下 什么情况下是D{{ 什么情况下是DY{