Hey,please send email to user...@apache.org <mailto:user...@apache.org> address to discuss user questions if you’d like to use Chinese, the d...@apache.org <mailto:d...@apache.org> is used to discuss development related tasks and English is required in this mailing list.
Best, Leonard > 2024年6月3日 下午2:03,bbcca...@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(); > > > bbcca...@163.com