请问下大家同步mysql的decimal(10, 2)类型怎么到cdc后是这样的"total_amo

1. 问题描述： 用户在同步MySQL数据库中decimal(10, 2)类型的数据到CDC（Change Data Capture）过程中，发现原本的数值变成了字符串格式，例如"total_amount":"CHYE"。

2. 查询背景：

   • 涉及数据库系统：MySQL作为源数据库。
   • 使用技术：Flink CDC进行数据同步。
   • 业务需求：保持数值类型的正确同步，避免数据类型转换错误。

3. 问题分析：

   • 原因分析：该问题可能是由于Flink CDC在读取MySQL的Decimal类型时，默认的反序列化设置不匹配，导致数值被错误地解析为字符串。
   • 相关知识库参考：

4. 解决方案：

   • 需要在Flink作业配置中调整Debezium的属性，以确保Decimal类型能正确转换。具体操作如下：

   Properties properties = new Properties();
   properties.setProperty("decimal.handling.mode", "double"); // 或者使用"string"、"precise"等其他适合的处理模式
   

   然后将这些属性应用到你的Flink MySQL Source配置中：

   MySqlSource.<String>builder()
      .hostname(config.getHostname())
      // 其他配置...
      .debeziumProperties(properties)
      .build();
   

5. 注意事项：

   • 使用"decimal.handling.mode","double"会将Decimal转换为Java的double类型，可能会有精度损失。
   • 若需保持高精度无损转换，可尝试使用"precise"模式，但需注意这可能对系统资源有更高要求。
   • 调整前请评估此更改对下游系统的兼容性和影响。

6. 参考资料：

   • Flink CDC配置与Decimal类型处理

通过上述方案，您可以解决MySQL decimal(10, 2)类型数据同步至Flink CDC过程中出现的类型转换异常问题，确保数据的准确性和一致性。