Flink CDC里关于#2217问题有后续吗,最后帖子说的【从指定的binlog位点启动】这个功能有没有实现方式?
关于Flink CDC中的#2217问题,目前还没有明确的后续。该问题涉及到从指定的binlog位点启动功能,但目前还没有实现方式。
从指定的binlog位点启动是指在Flink CDC中,用户可以选择从特定的binlog位置开始读取和处理数据,而不是从最早的binlog位置开始。这对于一些需要从特定时间点开始消费数据的场景非常有用。
然而,目前Flink CDC并没有提供直接的方式来实现这个功能。用户仍然需要手动指定起始的binlog位置,并确保该位置之前的所有事件都已经成功处理。
如果你对这个问题感兴趣,可以考虑在Flink社区中提出一个新的issue,以讨论和推动该功能的实现。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。