潍坊搜易网站建设,怎么做网站导流生意,电子商务网站设计的三大原则,自己做网站语言包怎么做Flink CDC MySQL 表字段定义为 decimal 输出乱码问题解析
代码运行环境
Flink 1.15 + FlinkCDC 2.4.0 + jdk1.8 +springboot 2.31、原因分析
Flink CDC 底层使用 Debezium 连接器来捕获 MySQL 的数据变更。当 MySQL 表中的字段类型为 decimal 时，Debezium 默认会将 decimal…Flink CDC MySQL 表字段定义为 decimal 输出乱码问题解析
代码运行环境
Flink 1.15 + FlinkCDC 2.4.0 + jdk1.8 +springboot 2.31、原因分析
Flink CDC 底层使用 Debezium 连接器来捕获 MySQL 的数据变更。当 MySQL 表中的字段类型为 decimal 时，Debezium 默认会将 decimal 类型的数据转换为二进制格式（java.math.BigDecimal）进行传输。然而，在 Flink 中，如果直接使用默认的反序列化方式，可能会导致 decimal 数据无法正确解析，从而出现乱码问题。这是由于 Flink 和 Debezium 在处理 decimal 类型数据时的格式不完全兼容所导致的。
2、解决方案
使用 JsonDebeziumDeserializationSchema 自定义转换规则参数 MapString, Object customConverterConfigs configs.put("decimal.format",
