问题一:flink cdc 能对pgsql做增量数据抽取吗?有参考指导一下吗?
flink cdc 能对pgsql做增量数据抽取吗?有参考指导一下吗?
参考答案:
支持,使用Incremental Snapshot的 latest-offset 。参考:
https://apache.github.io/flink-cdc/master/content/connectors/postgres-cdc.html
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/602743
问题二:Flink SQL能写delete语句吗?
Flink SQL能写delete语句吗?通过Kafka的数据关联删除JDBC的数据
参考答案:
当然可以写。需要在flink中配置MYSQL连接,然后就就正常写sql语句就可以了。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/602742
问题三:使用flink CDC的flinksql可以不传输delete的数据吗?
使用flink CDC的flinksql可以不传输delete的数据吗?或通过 WITH ('connector' 实现 ,或通过flink的配置文件,能实现吗?
参考答案:
sql连接器是支持的,如上官网去找sql的连接器。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/602739
问题四:怎么使用flinkcdc读取oracle中的blob类型的数据?
怎么使用flinkcdc读取oracle中的blob类型的数据?在sql-client 中select * from source端; blob为null
参考答案:
可以看下这个:
https://debezium.io/documentation/reference/1.9/connectors/oracle.html#oracle-property-lob-enabled 。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/602735
问题五:Flink CDC 里这是什么情况?
Flink CDC 里这是什么情况?
参考答案:
flink-cdc-common-3.0.1.jar 这个包加进去试一下。
关于本问题的更多回答可点击进行查看: