测试表基础数据:测试表基础数据

例如只转换flag=1的记录

转换规则:PASS(SQLTYPE=(ON=INSERT,ON=UPDATE,ON=DELETE),CONDITION=(flag=1))

(1)更新flag=1的记录,update会转换成delete+insert操作

update操作:

手动消费转换后的topic:

update操作根据before值补全after值的列(zcbus-7.6-9-20210727.tar.gz版本后):

(2)更新flag=1的记录set flag=0,update会转换成delete操作

update操作:

手动消费转换后的topic:

(3)更新flag=0的记录set flag=1,update会转换成insert操作

update操作:

手动消费转换后的topic:

update操作根据before值补全after值的列(zcbus-7.6-9-20210727.tar.gz版本后):

手动消费转换后的topic命令:

../bin/kafka_tool -broker 172.17.58.146:9092 -topic 37358.zfl.test_etl.r.test_etl_oracle.37357 -offset 0
文档更新时间: 2023-10-22 14:47   作者:阿力