Canal+kafka,'data': [{...],所有字段均成String类型？
在kafka上监控CANAL写入的数据，其中data部分，所有字段的值均变成String,如 'RENTAL_INCOME_I1': '0.0', 'RENTAL_INCOME_I2':'0.0', 'RECE_PRINCIPAL': '0'，在MYSQL中均是decimal类型，请问是为什么出现这现象呢？
原提问者GitHub用户windtalkerbj
写回答
-
-
随心分享，欢迎友善交流讨论：）这个现象可能是由于在 Canal 的数据同步过程中，数据类型发生了变化，从而导致了数据类型不一致的问题。
具体来说，Canal 在进行数据同步时，会将 MySQL 中的数据转换成 JSON 格式，并使用 Avro 或 Protobuf 进行序列化后写入 Kafka。在这个过程中，Canal 会根据 MySQL 中的数据类型来选择相应的数据类型进行序列化，但是有些数据类型可能无法直接转换成 Avro 或 Protobuf 中的数据类型。比如 MySQL 中的 Decimal 类型，如果在 Canal 中无法正确处理，就会被转换成字符串类型写入 Kafka。
为了解决这个问题，可以尝试升级 Canal 的版本，或者在 Canal 中使用自定义的数据类型映射规则，将 MySQL 中的 Decimal 类型映射成 Avro 或 Protobuf 中的相应数据类型。同时，也可以在 Kafka 消费端对数据进行处理，将字符串类型的数据转换成相应的数据类型。
2023-05-04 17:58:47赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
