2023-07-13 19:36:51,244 WARN io.debezium.connector.mysql.MySqlValueConverters [] - Invalid value '0000-00-00 00:00:00.000' stored in column 'refundtime' of table 'db.t1' converted to empty value
请问flinc cdc 中cdc转换器的这个功能能禁用吗?让他原样输出'0000-00-00 00:00:00.000' ,sql方式。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
Flink CDC(Change Data Capture)中的转换器用于将源表的数据类型转换为 Flink 中的对应数据类型。默认情况下,CDC 转换器会将无效值(例如 '0000-00-00 00:00:00.000')转换为空值(empty value)。
如果您想要禁用 CDC 转换器的功能,以便原样输出无效值,可以通过以下方式进行配置:
debezium.transforms
部分添加以下配置:"transforms": "outbox",
"transforms.outbox.type": "io.debezium.transforms.ExtractNewRecordState",
"transforms.outbox.drop.tombstones": false
Properties
对象中添加以下配置:properties.setProperty("transforms", "outbox");
properties.setProperty("transforms.outbox.type", "io.debezium.transforms.ExtractNewRecordState");
properties.setProperty("transforms.outbox.drop.tombstones", "false");
上述配置中,transforms.outbox.drop.tombstones
设置为 false
将禁止丢弃无效值。
本技术圈将为大家分析有关阿里云产品Hologres的最新产品动态、技术解读等,也欢迎大家加入钉钉群--实时数仓Hologres交流群32314975