测试表基础数据:测试表基础数据
例如只转换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 作者:阿力