当前mysqlSouce仅支持 StartupOptions.INITIAL和LATEST_OFFSET。 想要根据位点或者时间戳发起binlog订阅,有老哥知道未来什么时候支持么?
对于Flink的MySQL Source Connector,目前确实只支持使用StartupOptions.INITIAL
和StartupOptions.LATEST_OFFSET
来初始化和启动binlog订阅。这意味着您只能从最早的binlog事件或最新的binlog事件开始订阅。
关于是否会在未来支持根据位点或时间戳发起binlog订阅,我无法提供确切的时间表或计划。Flink社区在不断发展和改进,新的功能和改进可能会在未来的版本中加入。建议您关注Flink的官方文档、邮件列表或社区讨论,以获取最新的更新和动态。
另外,如果您有特定的需求,您也可以考虑自定义开发或贡献代码来实现根据位点或时间戳发起binlog订阅的功能。Flink是一个开源项目,欢迎社区成员的贡献和扩展。您可以参考Flink的开发文档和社区指南,了解如何进行自定义开发和贡献代码。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。