首页flink cdc oracle

flink cdc oracle

时间: 2023-08-31 11:12:15 浏览: 164

Flink CDC Oracle是基于Flink的Oracle Change Data Capture（CDC）功能，用于实时采集Oracle数据库的数据变更。它使用了debezium框架，并利用Oracle数据库自带的logminer技术来实现数据采集。在配置Flink CDC Oracle时，需要注意的是，如果Oracle的dbName配置的是SID而不是service_name，可能会导致连接失败。解决这个问题的方法是将jdbc链接字符串改为jdbc:oracle:thin:@localhost:1521:sid的方式。你可以通过API方式或Flink SQL方式手动指定这个链接字符串，例如使用基于API的方式可以设置properties.put("database.url","jdbc:oracle:thin:@localhost:1521:sid")。总结来说，Flink CDC Oracle是用于实时采集Oracle数据库数据变更的工具，它基于Flink并使用debezium和Oracle的logminer技术实现。在配置时需要注意正确设置链接字符串，特别是当dbName配置为SID时。123 #### 引用[.reference_title] - *1* [flink1.14.3 cdc jar包](https://download.csdn.net/download/weixin_46661903/84678566)[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^v93^chatsearchT3_1"}}] [.reference_item style="max-width: 50%"] - *2* *3* [Flink Oracle CDC Connector源码解读](https://blog.csdn.net/IT_xhf/article/details/130364090)[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^v93^chatsearchT3_1"}}] [.reference_item style="max-width: 50%"] [ .reference_list ]

阅读全文