问题一:flinkcdc可以采集sqlserver的从节点吗?
flinkcdc可以采集sqlserver的从节点吗?
参考答案:
可以的
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/584523
问题二:Flink CDC这些参数如果要调整的话,在代码里怎么调整?
Flink CDC这些参数如果要调整的话,在代码里怎么调整?貌似没看到set 的方法
参考答案:
com.ververica.cdc.connectors.postgres.source.PostgresSourceBuilder#splitSize
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/584519
问题三:Flink CDC代码是在哪个方法里面加配置?
Flink CDC代码是在哪个方法里面加配置?
参考答案:
代码你用这个source就自动是了,sql设置为false的时候用的是com.ververica.cdc.connectors.postgres.PostgreSQLSource
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/584517
问题四:Flink CDC中pg cdc使用 Incremental Snapshot时,还需要额外设置吗?
Flink CDC中,pg cdc 使用 Incremental Snapshot时,代码里面 JdbcIncrementalSource.splitSize(2) 还需要额外设置
scan.incremental.snapshot.enabled=true 吗?
参考答案:
要先开 scan.incremental.snapshot.enabled=true 的,不然用的是旧的source
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/584515
问题五:遇到Flink CDC同步中文表和中文列乱码怎么处理吗?
遇到Flink CDC同步中文表和中文列乱码怎么处理吗?
参考答案:
Try to set env.java.opts: -Dfile.encoding=UTF-8 in flink-conf.yaml (the option is changed to env.java.opts.all since Flink-1.17).
关于本问题的更多回答可点击进行查看: