请教一下,Flink CDC中sqlsever作为source什么时候能支持无锁读取和动态加表呢?
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
根据现有的知识库资料,目前关于Flink CDC支持SQL Server作为Source的相关功能(如无锁读取和动态加表)并未明确提及。以下是对当前已知信息的分析和建议:
在现有资料中,无锁读取的功能主要针对Postgres CDC连接器进行了描述。例如,Postgres CDC支持无锁读取全量数据,以避免对线上业务造成影响。然而,对于SQL Server作为Source的场景,当前的知识库中没有提到类似功能的支持。
因此,可以推测Flink CDC目前尚未实现SQL Server的无锁读取功能。如果需要该功能,建议关注Flink CDC的后续版本更新,或者考虑通过社区反馈需求。
动态加表的功能在部分场景中有所提及。例如,在CDAS(Create Database As)语句中,Flink CDC支持在作业运行过程中捕获新增表并继续同步数据。此外,STATEMENT SET语法也允许将多个CTAS(Create Table As)语句合并为一个作业提交,并优化Source复用。
然而,这些动态加表的能力主要针对MySQL CDC源表进行了详细说明,而对于SQL Server作为Source的场景,当前知识库中没有相关支持的描述。
由于SQL Server作为Source的无锁读取和动态加表功能尚未明确支持,您可以考虑以下替代方案:
Flink CDC的功能正在不断扩展和完善。例如,MongoDB CDC连接器在近期版本中正式进入生产阶段,并提供了丰富的功能支持。因此,SQL Server作为Source的无锁读取和动态加表功能可能会在未来版本中得到支持。建议您持续关注Flink CDC的官方发布文档,或者通过阿里云的技术支持渠道提交需求。
如果您有进一步的具体需求或问题,欢迎随时补充说明!