在Flink CDC中，你这个把这个参数去掉 那延迟就很大 你们是怎么解决的呢 ？

Properties oracleProp = new Properties();
//将数据库DECIMAL, NUMBER, NUMERIC和REAL 等数据类型的值转为String类型
oracleProp.put(PropertiesConstant.DECIMAL_MODEL,PropertiesConstant.DECIMAL_MODEL_VALUE);
//监控时序SCN范围
oracleProp.put(PropertiesConstant.BATCH_SIZE,"20000000");
oracleProp.setProperty(PropertiesConstant.STRATEGY, PropertiesConstant.STRATEGY_VALUE);
// oracle 19c及以上版本去掉log.mining.continuous.mine,否则会报错
if (!PropertiesConstant.ORACLE_DB_VERSION.equals(param.getOracleVersion())) {
oracleProp.setProperty(PropertiesConstant.CONTINUOUS, PropertiesConstant.CONTINUOUS_VALUE);
}
// flase 禁止表名转为小写，否则转小写
oracleProp.setProperty(PropertiesConstant.INSENSITIVE, PropertiesConstant.INSENSITIVE_VALUE);
// snapshot.mode initial快照全量 schema_only增量
oracleProp.setProperty(PropertiesConstant.SNAPSHOT_MODE, param.getStartupModel());
if ("Y".equals(param.getCdcFlag())) {
oracleProp.setProperty(PropertiesConstant.PDBNAME, param.getPdbName());
}
// 指定了LogMiner会话在停止并开始解除分配和重新分配PGA内存之前可以处于活动状态的最大毫秒数
oracleProp.setProperty(PropertiesConstant.SESSION_MAX, PropertiesConstant.SESSION_MAX_VALUE);
return oracleProp; 在Flink CDC中，你这个把这个参数去掉 那延迟就很大 你们是怎么解决的呢 ？