关于Flink CDC，Debezium 监听orcl 怎么操作？

flink使用oracle cdc连接器时数据延迟较大，需加入debezium参数进行调整，以下代码均已加入该配置。

Properties properties = new Properties();
//设置数据库连接参数（表名大小写转换）
properties.setProperty("database.tablename.case.insensitive","false");
properties.setProperty("database.connection.adapter", "logminer");
//降低oracle cdc 延迟
properties.setProperty("log.mining.strategy", "online_catalog");
properties.setProperty("log.mining.continuous.mine", "true");

//创建Stream环境
Configuration configuration = new Configuration();

StreamExecutionEnvironment env =
                StreamExecutionEnvironment.getExecutionEnvironment(configuration);

//oracle 连接器配置
SourceFunction<String> build = OracleSource.<String>builder()
                .hostname("localhost")
                .port(1521)
                .database("XE") // monitor XE database
                .schemaList("test") // monitor test schema
                .tableList("DBTEST.tbtest1," +
                            "DBTEST.TBTEST2") // monitor tables
                .username("flinkuser")
                .password("flinkpw")
                //从最新位置读取，可自行修改initial()、latest()
                .startupOptions(com.ververica.cdc.connectors.oracle.table.StartupOptions.latest())
                .deserializer(new FlinkCdcDataDeserializationSchema()) // converts SourceRecord to JSON String
                .debeziumProperties(properties)
                .build();

env.setParallelism(2);

DataStreamSource<String> stringDataStreamSource = env.addSource(build);

stringDataStreamSource.addSink(new CustomSink());

env.execute();