问题1:请问Flink CDC中有数据库方言转换方案推荐吗？客户现场存在异构数据源的同一系统，如mysql版本、达梦数据库版本，现在客户想实现两套系统进行数据实时同步功能。我的思路是，通过拦截SQL方式通过消息中间件（kafka、rabbitmq）发送给另外一个节点，节点收到数据后，进行一个SQL解析和转换，把源SQL转换为当前设备数据库SQL。我打算通过mybatis，把sql拦截下来，然后通过消息中间件发给另外一台机器，另外一台机器把源数据源sql转换为目标数据源sql，比如mysql 语句转换为达梦的。 问题2:现在是SQL解析转换这块，没有一个很好的思路，您有好的建议吗？
请问Flink CDC中有数据库方言转换方案推荐吗？客户现场存在异构数据源的同一系统，如mysql版[阿里云实时计算 Flink版]
「点点赞赏，手留余香」
还没有人赞赏，快来当第一个赞赏的人吧！