Flink CDC为什么我同步mongodb到kafka完成后点击savepoint停止?

Flink CDC为什么我同步mongodb到kafka完成后点击savepoint停止后,savepoint那么大?mysql到kafka就不会有这个问题

Flink CDC消费kafka的时候使用latest,用savepoint启动后不生效?

Flink CDC消费kafka的时候使用latest,用savepoint启动后不生效,中间的数据都漏掉了,这个有办法解决吗?

消息队列Kafka入门课程

4 课时 |
3098 人已学 |
免费

分布式消息系统 Kafka 快速入门

24 课时 |
640 人已学 |
免费
开发者课程背景图

Flink的kafka连接器在latest消费,savepoint不生效有大佬遇到吗?

Flink的kafka连接器在latest消费,savepoint不生效有大佬遇到吗?

有遇到过从oracle抽数到kafka,源表新增字段后从savepoint重启任务导致kafka里新

有遇到过从oracle抽数到kafka,源表新增字段后从savepoint重启任务导致kafka里新增字段值为空的问题嘛?

修改topic名称后从Savepoint重启会怎么消费Kafka?

Hi,大佬们 突然有一个疑问点,Flink消费kafka的Job保存了SP之后停止,修改代码中的topic名称之后重启。 会从新topic的哪里开始消费?与startup-mode一致,还是从最新呢? 可以手动控制么? *来自志愿者整理的flink邮件归档

通过savepoint重启任务,link消费kafka,为什么有重复消息?

大家好,我有一个flink job, 消费kafka topic A, 然后写到kafka topic B. 当我通过savepoint的方式,重启任务之后,发现topic B中有重复消费的数据。有人可以帮我解答一下吗?谢谢! My Versions Flink 1.12.4 Kafka 2.0.1...

flink 从kafka消费,savepoint后,重启拓扑,kafka topic对应的offset值不是存到zookeeper了?

flink 从kafka消费,savepoint后,重启拓扑,kafka topic对应的offset值不是存到zookeeper了?

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

社区圈子

消息队列
消息队列
消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。
20+人已加入
加入
相关电子书
更多
消息队列 Kafka 版差异化特性
2019大数据技术公开课第五季—kafka 数据如何同步到 MaxCompute
任庆盛|Flink CDC + Kafka 加速业务实时化
立即下载 立即下载 立即下载