I have read the doc ncremental-snapshot-based-datastream-experimental
<https://nightlies.apache.org/flink/flink-cdc-docs-release-3.0/docs/connectors/legacy-flink-cdc-sources/oracle-cdc/#incremental-snapshot-based-datastream-experimental>
,
and run the example code. It works. but I also need to get the ddl changes,
so I change the debeziumProperties.setProperty("log.mining.strategy",
"online_catalog");
to debeziumProperties.setProperty("log.mining.strategy",
"redo_log_catalog");
after I run the modified code, there is nothing print in the console.
I set a breakpoint at JsonDebeziumDeserializationSchema#deserialize method,
the method not invoked at all.
why? how to resolve this?

Reply via email to