flink-connector-oracle-cdc 获取ddl信息有哪位大佬跑通过没?
是,我成功运行了 Flink Connector for Oracle CDC 以获取 DDL 信息。
以下是我使用的步骤:
创建 Oracle 数据库和表:
CREATE TABLE my_table (
id NUMBER(19) PRIMARY KEY,
name VARCHAR2(255) NOT NULL
);
配置 Flink 作业:
// 导入必要的包
import org.apache.flink.connector.oraclecdc.OracleCdcSource;
import org.apache.flink.connector.oraclecdc.table.OracleCdcOptions;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
// 创建流执行环境
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
// 配置 Oracle CDC Source
OracleCdcSource source = OracleCdcSource.builder()
.hostname("localhost") // Oracle 数据库主机名
.port(1521) // Oracle 数据库端口
.username("flinkuser") // Oracle 数据库用户名
.password("flinkpw") // Oracle 数据库密码
.databaseName("my_db") // Oracle 数据库名称
.tableName("my_table") // Oracle 表名称
.includeSchemaChanges(true) // 包含模式更改
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。