Flink CDC读取kafka中的订单和订单明细数据，同步到sink表后，这一般是什么问题啊？
Flink CDC读取kafka中的订单和订单明细数据，同步到sink表后，sink表的数据数量一直跳来跳去，一会几百条一会变成几十条，这一般是什么问题啊？感觉总是最后一次数据【新产生的一小部分流数据】，会把sink表中所有历史数据都清空掉用的mysql: CREATE TABLE sink_sal...
Flink CDC中sink如果异常了 ，如何处理？ 比如kafka宕机。数据会丢吗？
Flink CDC中sink如果异常了 ，如何处理？ 比如kafka宕机。数据会丢吗？
Flink CDC两台服务器传输数据，在sink端部署kafka接收数据，是否可行？
问题1:Flink CDC两台服务器传输数据，相互间无法访问对方的数据库，但服务器ip可以ping通，无法使用flink sql模式同步如果我在source端使用flink cdc捕获数据，在sink端部署kafka接收数据，是否可行？类似于这种模式？问题2:采用这种模式？source端使用debe...
Flink CDC这个第六步一定要写kafka吗？ 直接写sink库不写kakfa不行吗？
Flink CDC这个第六步一定要写kafka吗？ 直接写sink库不写kakfa不行吗？ 另外如果flink中断了， 不是有checkpoint吗？ checkpoint不存储上一次的scn吗？ 为何要依赖kafka？
Flink1.17.1 sink kafka, 总是输出 disconnected 的日志,正常吗？
Flink1.17.1 sink kafka, 总是输出 disconnected 的日志, 正常吗? INFO org.apache.kafka.clients.NetworkClient [] - [Producer clientId=producer-4] Node 107928 discon...
Flink CDC有sink到kafka的方法吗？我看官方的就是要引入flink-connector
Flink CDC有sink到kafka的方法吗？我看官方的就是要引入flink-connector-kafk
Flink的sink实战之二：kafka
欢迎访问我的GitHub 这里分类和汇总了欣宸的全部原创(含配套源码)：https://github.com/zq2599/blog_demos 本文是《Flink的sink实战》系列的第二篇，前文《Flink的sink实战之一：初探》对sink有了基本的了解，本章来体验将数据sink到kafka的...
flink cdc source mysql sink kafka 报包冲突 如何解决？
问题1：flink cdc source mysql sink kafka 报包冲突 如何解决？问题2：这个也看不出问题。我cdc 2.4 flink 1.13.6
Flink中自定义的sink 如果kafka 已经发送消息了，这个是ck会不会被认为完成。但是最终？
Flink中自定义的sink 如果kafka 已经发送消息了，这个是ck会不会被认为完成。但是最终这个消息发送失败了？
Flink中cdas整库同步是否支持sink段到kafka形成一个topic？目前我知道是不可以的，
Flink中cdas整库同步是否支持sink段到kafka形成一个topic？目前我知道是不可以的，不知道未来会不会这样做，那就只能用datastream接入全部数据打入kafka单topic了，加解密数据，愁死人了，加解密还不让我们来操作 看来得看看paimon
更新时间 2023-09-28 21:52:59
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。
社区圈子
