如果是到单库,单表的话,oracle到mysql、oracle、sqlserver我测试都通了,到doris的话能同步多表
-- 同步F360表
$FLINK_HOME/bin/flink run \
-Dexecution.checkpointing.interval=180 \
-Dparallelism.default=1 \
-c org.apache.doris.flink.tools.cdc.CdcTools \
./lib/flink-doris-connector-1.17-1.6.0-cdc-3.0.1.jar \
oracle-sync-database \
--database app_db \
--oracle-conf hostname=192.168.9.100 \
--oracle-conf port=1521 \
--oracle-conf username=regenta \
--oracle-conf password="regenta2017" \
--oracle-conf database-name=REGENTA \
--oracle-conf schema-name=REGENTA \
--including-tables "SALELIST|SALELISTGOODS|CHANNEL|GOODS|MEMBERCARD|BUSINESSPERSON|SALETYPE_VW|BUSCH" \
--oracle-conf debezium.database.history.store.only.captured.tables.ddl=true\
--sink-conf fenodes=192.168.9.168:8030 \
--sink-conf username=root \
--sink-conf password="83320843"\
--sink-conf jdbc-url=jdbc:mysql://192.168.9.168:9030 \
--sink-conf sink.label-prefix=F360 \
--table-conf replication_num=1
你要注意表名大小写,这个配置是可以一个任务同时同步几个表的,用的是flink1.17.2,doris是2.0.6 ,此回答整理自钉群“【②群】Apache Flink China社区”
Flink CDC成功支持了从Oracle数据库到多种目标数据存储的实时数据同步。无论是同步到另一个Oracle数据库,MySQL数据库,还是StarRocks数据仓库,都已经验证是可以实现的。通过利用Debezium Oracle Connector和Flink的流处理能力,可以从Oracle数据库捕获变更数据,并实时传输到目标系统。
要实现Oracle到其他系统的实时同步,需要完成以下步骤:
综上所述,Flink CDC已经成功实现了对Oracle数据库的CDC支持,并能够将数据实时同步到各种目标存储系统。在实际使用中,需要根据官方文档指导和最佳实践来配置和运行同步任务。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。