问题一:在Flink CDC中如下包在哪下载?
在Flink CDC中flink-cdc-pipeline-connector-postgresql-3.1.0.jar包在哪下载?
参考答案:
下载链接如下:
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/657813
问题二:在Flink CDC中人大金仓可以兼容PG的wal2json和Decoderbufs插件不?
在Flink CDC中人大金仓可以兼容PG的wal2json和Decoderbufs插件不,如果不支持有没有类似的方案?
参考答案:
Flink CDC目前不直接兼容人大金仓数据库(Kingbase)的PG wal2json和Decoderbufs插件。Flink CDC主要针对MySQL、PostgreSQL等数据库提供了原生支持。对于人大金仓数据库,阿里云提供了MaxCompute CDC服务,它可以用于实时同步Kingbase的数据到MaxCompute。如果需要将Kingbase的数据同步到其他系统,您可能需要寻找第三方工具或自定义开发解决方案。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/657819
问题三:在Flink CDC中取Oracle的数据,拿不到clob类型的数据如何解决?
在Flink CDC中取Oracle的数据,拿不到clob类型的数据如何解决?
参考答案:
用flink string拿。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/657791
问题四:在Flink CDC中请问flinkcdc-oracle3.1.1 也需要额外上传ojdbc嘛?
在Flink CDC中请问flinkcdc-oracle3.1.1 也需要额外上传ojdbc嘛?
参考答案:
是的,协议不同了。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/657850
问题五:在Flink CDC中请问datastream控制连接数 是这么配置吗?
在Flink CDC中请问datastream控制连接数 是这么配置吗?请参考图片:
参考答案:
直接buider.connectionPoolSize设置,不要放在properties里面。
关于本问题的更多回答可点击进行查看: