flink 连接Oracle
时间: 2023-11-07 07:52:24 浏览: 155
flink1.12.2 连接oracle jdbc jar包
Flink连接Oracle数据库的配置方式根据不同版本有所不同。在Oracle19c版本中,可以使用以下配置项来解决读取数据延迟的问题:'debezium.log.mining.strategy'='online_catalog'和'debezium.log.mining.continuous.mine'='true'。但是在Oracle19c中取消了该组件的配置,所以需要使用Oracle12c版本。在使用Oracle12c版本时,需要在创建用户和授权时进行一些调整,以避免在Flink中调用DBMS_LOGMNR.START_LOGMNR时出现“用户不存在”的问题。同时,需要重新打包flink-connector-jdbc并替换Flink集群中原生的jar包,将Oracle或者SQL Server的驱动放入其中。代码调用方式与MySQL没有太大不同,可以参考《FLINK 1.12.2 jdbc读写mysql》中的具体方法进行配置。<em>1</em><em>2</em><em>3</em>
#### 引用[.reference_title]
- *1* *2* [Flink connector Oracle CDC 实时同步数据到MySQL(Oracle12c)](https://blog.csdn.net/qq_23502409/article/details/126040480)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v92^chatsearchT3_1"}} ] [.reference_item]
- *3* [FLINK 1.12.2 jdbc实现oracle或sqlserver连接器](https://blog.csdn.net/arwenlin/article/details/116986258)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v92^chatsearchT3_1"}} ] [.reference_item]
[ .reference_list ]
阅读全文