问答 2022-08-12 来自:开发者社区

各位,我flink读取kafka两个topic数据,然后双流join,把统计数据写到mysql,现在

各位,我flink读取kafka两个topic数据,然后双流join,把统计数据写到mysql,现在需要切换新的kafka集群,要做到业务方无感知,数据不能延迟也不能有误差。我想了下,从checkpoint重启肯定不行了,但是不从checkpoint重启中间状态就没了,有谁遇到过或有什么解决办法吗

问答 2022-06-30 来自:开发者社区

大佬们目前flinksql, cdcmysql跟Kafka双流join,结果放到mysql 或者ka

大佬们目前flinksql, cdcmysql跟Kafka双流join,结果放到mysql 或者kafka, 两端数据都变化的情况,join结果没啥子的问题吧?有公司生产上在跑的案例没得

问答 2020-04-21 来自:开发者社区

想问下为什么kafka双流join的时候,每个流的算子都能执行,但是最后用flink sql joi

想问下为什么kafka双流join的时候,每个流的算子都能执行,但是最后用flink sql join的时候没有执行sql呢?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

消息队列

消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。

+关注