You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "bbccaaac@163.com" <bb...@163.com> on 2024/06/03 06:03:35 UTC

flink cdc 是否支持oracle rac

查看debezium 1.9.8文档是支持oracle rac的，但flink cdc oracle rac不管怎么配置都无法获取到源库数据，是我的配置不对吗？应该如何配置？
debeziumProperties.setProperty("rac.nodes", "172.16.140.254,172.16.140.253,172.16.140.252");
debeziumProperties.setProperty("debezium.log.mining.strategy", "online_catalog");
debeziumProperties.setProperty("debezium.log.mining.continuous.mine", "true");DebeziumSourceFunction<TestFb> sourceFunction = OracleSource.<TestFb>builder()
           .hostname("172.16.140.150")
           .port(1521)
           .database("testracdb")
           .schemaList("kfz") // monitor inventory schema
           .tableList("kfz.test_fb") // monitor products table
           .username("sync")
           .password("123456")
           .startupOptions(StartupOptions.latest())
           .debeziumProperties(debeziumProperties)
           .deserializer(new TestFbDeserializationSchema()) 
           .build();


bbccaaac@163.com

Re: flink cdc 是否支持oracle rac

Posted by Leonard Xu <xb...@gmail.com>.

Hey，please send email to user-zh@apache.org <ma...@apache.org> address to discuss user questions if you’d like to use Chinese, the dev@apache.org <ma...@apache.org> is used to discuss development related tasks and English is required in this mailing list.

Best,
Leonard 

> 2024年6月3日 下午2:03，bbccaaac@163.com 写道：
> 
> 查看debezium 1.9.8文档是支持oracle rac的，但flink cdc oracle rac不管怎么配置都无法获取到源库数据，是我的配置不对吗？应该如何配置？
> debeziumProperties.setProperty("rac.nodes", "172.16.140.254,172.16.140.253,172.16.140.252");
> debeziumProperties.setProperty("debezium.log.mining.strategy", "online_catalog");
> debeziumProperties.setProperty("debezium.log.mining.continuous.mine", "true");DebeziumSourceFunction<TestFb> sourceFunction = OracleSource.<TestFb>builder()
>           .hostname("172.16.140.150")
>           .port(1521)
>           .database("testracdb")
>           .schemaList("kfz") // monitor inventory schema
>           .tableList("kfz.test_fb") // monitor products table
>           .username("sync")
>           .password("123456")
>           .startupOptions(StartupOptions.latest())
>           .debeziumProperties(debeziumProperties)
>           .deserializer(new TestFbDeserializationSchema()) 
>           .build();
> 
> 
> bbccaaac@163.com