开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

当前mysqlSouce仅支持 StartupOptions.INITIAL和LATEST_OFF

当前mysqlSouce仅支持 StartupOptions.INITIAL和LATEST_OFFSET。 想要根据位点或者时间戳发起binlog订阅,有老哥知道未来什么时候支持么?2013问.png

展开
收起
游客3oewgrzrf6o5c 2022-07-22 15:48:04 378 0
1 条回答
写回答
取消 提交回答
  • 不断追求着最新的技术和趋势,在云技术的世界里,我不断寻找着新的机会和挑战,不断挑战自己的认知和能力。

    对于Flink的MySQL Source Connector,目前确实只支持使用StartupOptions.INITIALStartupOptions.LATEST_OFFSET来初始化和启动binlog订阅。这意味着您只能从最早的binlog事件或最新的binlog事件开始订阅。

    关于是否会在未来支持根据位点或时间戳发起binlog订阅,我无法提供确切的时间表或计划。Flink社区在不断发展和改进,新的功能和改进可能会在未来的版本中加入。建议您关注Flink的官方文档、邮件列表或社区讨论,以获取最新的更新和动态。

    另外,如果您有特定的需求,您也可以考虑自定义开发或贡献代码来实现根据位点或时间戳发起binlog订阅的功能。Flink是一个开源项目,欢迎社区成员的贡献和扩展。您可以参考Flink的开发文档和社区指南,了解如何进行自定义开发和贡献代码。

    2023-07-22 23:08:42
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关电子书

更多
Using Hadoop to build a Data Quality Service for both real-time and batch data 立即下载
低代码开发师(初级)实战教程 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载