请问一下哥哥们有没有用flink cdc从oracle拉数据的?是什么版本的oracle?官方是这样写的没错,但是想知道有没有实例运行过,我只跑通官方给的11g版本
Flink CDC 库支持从 Oracle 数据库中拉取变更数据,可以通过 Flink 的 FlinkCDCSource 来实现。目前,Flink CDC 库支持的 Oracle 数据库版本包括:
11g Release 2 (11.2.0.4)
12c Release 1 (12.1.0.2)
12c Release 2 (12.2.0.1)
如果您的 Oracle 数据库版本为以上任意一种,均可以使用 Flink CDC 库来实现数据变更的抓取和处理。
具体来说,您可以通过以下步骤来实现 Flink CDC 从 Oracle 数据库中拉取数据的功能:
配置 Oracle 数据库的连接参数:
maxima
Copy
Properties properties = new Properties();
properties.setProperty("database.hostname", "localhost");
properties.setProperty("database.port", "1521");
properties.setProperty("database.user", "user");
properties.setProperty("database.password", "password");
properties.setProperty("database.dbname", "dbname");
properties.setProperty("database.server.id", "1");
properties.setProperty("database.server.name", "oracle-cdc");
创建 Flink CDC Source:
clojure
Copy
FlinkCDCSource source = FlinkCDCSource.builder()
.hostname("localhost")
.port(1521)
.databaseList("dbname")
.tableList("schema.table")
.username("user")
.password("password")
.deserializer(new StringDebeziumDeserializationSchema())
.build();
将 Flink CDC Source 转换为 Flink DataStream:
Copy
DataStream stream = env.addSource(source);
需要注意的是,F
Flink CDC(Change Data Capture)模块可以用于从 Oracle 数据库中捕获变更数据并进行实时处理。根据 Flink 官方文档的说明,Flink CDC 模块支持以下版本的 Oracle 数据库:
- Oracle 11g - Oracle 12c - Oracle 19c
因此,您可以使用 Flink CDC 模块从这些版本的 Oracle 数据库中拉取数据进行实时处理。
需要注意的是,不同版本的 Oracle 数据库可能存在一些差异和限制,具体的配置和使用方法可以参考 Flink 的官方文档以及相应版本的 Oracle 文档。另外,在安装和配置 Flink CDC 模块时,确保正确设置数据库连接信息、用户权限和必要的依赖项,以确保正常运行。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。