Hey，please send email to [email protected] <mailto:[email protected]> address to discuss user questions if you’d like to use Chinese, the [email protected] <mailto:[email protected]> is used to discuss development related tasks and English is required in this mailing list.
Best, Leonard > 2024年6月3日 下午2:03，[email protected] 写道： > > 查看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(); > > > [email protected]
