有谁知道哪个版本的flink cdc 既支持startupoptions.specificoffset,又支持获取schemachanges?
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
根据知识库中的信息,实时计算Flink版支持的Flink CDC功能在不同版本中有所增强。对于您的需求,想要找到一个版本的Flink CDC既支持startupOptions.specificOffset
又能够获取Schema Changes,可以参考以下分析:
支持specificOffset: 虽然直接提及特定版本支持startupOptions.specificOffset
的资料有限,但此配置选项是Flink CDC较为基础的功能之一,通常用于指定从特定偏移量开始读取数据,广泛应用于控制作业启动时的数据读取位置。因此,多数较新且稳定的Flink版本应包含对此功能的支持。
获取Schema Changes: Flink CDC对Schema Changes的支持经历了发展,特别是在社区捐赠给Apache基金会后,其作为流式ETL框架的能力得到增强。文档中提到**【3】**MySQL CDC与Postgres SQL CDC支持Flink CDC社区2.3版本的所有功能,这表明至少在该提及的版本及之后,对Schema Changes的处理能力得到了显著提升。同时,使用DataStream API时可通过配置includeSchemaChanges(true)
来显式获取DDL事件。
结合上述信息,虽然没有直接指出满足两个条件的具体版本号,但考虑到Flink CDC项目的发展历程和特性集成,推荐关注Flink CDC 2.3及以上版本,尤其是那些强调了对CDC特性和Schema Evolution有显著增强的Flink发行版。实时计算Flink版不断迭代更新,引入了如动态CEP、更灵活的连接器配置(包括Hologres Connector的增强)以及对Flink CDC项目最新进展的支持,这些都间接表明了对您所需功能的支持趋势。
综上所述,为了获得同时支持startupOptions.specificOffset
和Schema Changes捕获的Flink版本,建议关注并使用Flink CDC 2.3或更高版本,并具体查阅相应版本的实时计算Flink版文档,以确认所选版本完全符合您的需求。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。