请问一下哥哥们有没有用flink cdc从oracle拉数据的？是什么版本的oracle？官方是这样写的没错，但是想知道有没有实例运行过，我只跑通官方给的11g版本
请问一下哥哥们有没有用flink cdc从oracle拉数据的？是什么版本的oracle？官方是这样[阿里云实时计算 Flink版]
「点点赞赏，手留余香」
还没有人赞赏，快来当第一个赞赏的人吧！
=====这是一个广告位，招租中，联系qq 78315851====
同尘云，您身边的云智能顾问
请问一下哥哥们有没有用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 模块时，确保正确设置数据库连接信息、用户权限和必要的依赖项，以确保正常运行。
现在就应该是支持11g,12c 还有19吧，此回答整理自钉群“【③群】Apache Flink China社区”