问题一:各位有没有flink cdc MySQL connector jar 分享?
各位有没有flink cdc MySQL connector jar 分享?
参考回答:
对于Flink CDC MySQL连接器的jar包,这里有一些版本可以供您参考:
- flink-connector-mysql-cdc-2.2.0.jar,这是一个基于flink 1.15.0的版本。
- flink-sql-connector-mysql-cdc-2.5-SNAPSHOT.jar,这个版本是开发分支release-XXX对应的快照版本,用户需要下载源代码并编译相应的 jar。
- flink-sql-connector-mysql-cdc:jar:2.3.0,这是另一个版本,需要配合flink-connector-jdbc:jar:3.0.0-1.16使用。
- flink-sql-connector-mysql-cdc-2.3-SNAPSHOT.jar,这个版本也是开发分支对应的代码,用户需要下载源代码并编译相应的jar。
- flink-sql-connector-mysql-cdc-1.1.0.jar,这是一个较新的版本,可以替换旧版本的jar包。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572298
问题二:Flink CDC胖包是啥?
Flink CDC胖包是啥?
参考回答:
cdc里面会包含这些依赖的
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572296
问题三:请问一下Flink CDC,上面的6个包为啥不需要?
请问一下Flink CDC,上面的6个包为啥不需要?
参考回答:
如果使用sql方式,需要sql的胖包,然后,cdc里面有debezium的相关依赖,你有可能会冲突,你这几个包都是不需要的
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572295
问题四:Flink CDC把算子链断开,但是我没看出写出的慢呢?
Flink CDC把算子链断开,但是我没看出写出的慢呢,我看发送和接收都正常,你这边是怎么判断我写出的慢呢?
参考回答:
看下dag
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572292
问题五:Flink CDC3.0有时间计划吗?
Flink CDC3.0有时间计划吗?
参考回答:
目前,对于Flink CDC 3.0的发布计划,Apache Flink社区还没有正式公布。Flink CDC 2.3.0版本已经增加了新的特性,例如支持按照时间戳获取数据。这种技术变革是通过将debezium.snapshot.mode配置设置为timestamp实现的,并通过debezium.snapshot.timestamp.mode配置指定时间戳的值。但是请注意,Flink CDC的版本更新和发布是一个持续的过程,具体到Flink CDC 3.0的发布日期,我们还需要关注Apache Flink的官方公告或者相关社区动态。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572291