问题一:Flink CDC中pipeline connector啥时候支持postgresql啊?
Flink CDC中pipeline connector啥时候支持postgresql啊?
参考答案:
Flink CDC的Pipeline Connector已经支持PostgreSQL。在2020年,就已经有教程展示如何基于 Flink CDC 快速构建 MySQL 和 Postgres 的流式 ETL。要使用PostgreSQL的CDC功能,首先需要下载flink-sql-connector-postgres-cdc的jar包,并将其放置在FLINK_HOME/lib/目录下。之后,就可以在Flink SQL CLI中进行相关操作了。具体操作方式你可以参考官方文档或者相关教程。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/580733
问题二:Flink CDC中pipeline connector 3.0.0目前只有MySQL 、3 个吗?
Flink CDC中pipeline connector 3.0.0 目前只有MySQL 、Apache Doris 和 StarRocks 3 个吗?
参考答案:
是的
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/580732
问题三:Flink CDC2.0以后不是已经实现了全程无锁吗?还需要自己设置吗?
Flink CDC2.0以后不是已经实现了全程无锁吗?还需要自己设置吗?我同步数据的时候dba反馈说锁表了,说其他任何写操作都会timeout
参考答案:
使用增量快照算法是无锁的,虽然是2.4的版本,但是必须用增量快照的语法,否则会加锁?
,不使用增量快照,历史数据同步的过程中会加锁,增量数据走的是日志,不能说语法,如果想使用增量快照,参考如上图所示的案例和包路径。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/580731
问题四:flinkcdc2.4版本,需不需要在sqlserver库也设置一些东西啊?
flinkcdc2.4版本,需不需要在sqlserver库也设置一些东西啊,比如隔离快照什么的,避免锁表什么的?
参考答案:
去看连接器文档里面有相关权限配置,https://ververica.github.io/flink-cdc-connectors/master/content/connectors/sqlserver-cdc.html
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/580730
问题五:Flink CDC在flink1.18.0版本需要添加吗
Flink CDC中flink sql 读取mysql 写入clickhouse,在flink1.18.0版本需要添加Flink ClickHouse Connector吗?
参考答案:
ververica-connector-clickhouse
关于本问题的更多回答可点击进行查看: