大佬 Flink CDC的官方上说的是不支持这个change-log但是我看cdc源码2.4的版本还是有这一块的代码的不知道我看的对不?
Flink CDC 官方文档中提到的“不支持的 change-log 类型”指的是 Flink CDC 2.4 版本中不支持的一些 change-log 类型。这些 change-log 类型包括:
Filesystem-based changelog:基于文件系统的 change-log 类型,不支持在 Flink CDC 2.4 版本中使用。
Kafka-based changelog:基于 Kafka 的 change-log 类型,不支持在 Flink CDC 2.4 版本中使用。
Debezium-based changelog:基于 Debezium 的 change-log 类型,不支持在 Flink CDC 2.4 版本中使用。
需要注意的是,尽管 Flink CDC 2.4 版本中不支持上述的 change-log 类型,但是 Flink CDC 2.4 版本中支持的 change-log 类型仍然非常丰富,包括 MySQL、PostgreSQL、Oracle、SQL Server 等多种类型。你可以根据具体的需求和环境,选择适合自己的 change-log 类型。
如果你在使用 Flink CDC 2.4 版本时需要使用上述不支持的 change-log 类型,可以考虑使用其他的 change-log 实现方式,或者尝试升级到 Flink CDC 的其他版本,以获得更好的支持和
根据您提供的截图,我无法确定具体指向的是哪一部分代码。然而,如果 Flink CDC 的官方文档明确说明不支持某个特定的 change-log 或功能,那么遵循官方文档是最可靠和推荐的做法。
在开源项目中,可能会出现文档滞后于实际代码的情况,或者某些功能可能正在进行开发中但尚未完全支持。这可以解释为什么您在源代码中看到了相关的代码,但官方文档却没有提及。
建议您仔细阅读官方文档,查找与您所关注的功能或 change-log 相关的详细信息。如果官方文档明确说明不支持该功能,那么请遵循官方文档的指导,并选择其他适合您需求的解决方案。
如果您对 Flink CDC 的源代码有更深入的了解,并且希望验证特定版本是否包含特定功能,请参考源代码或向 Flink CDC 社区寻求进一步的帮助。他们可以提供有关代码的准确信息,并回答您的疑问。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。