tianfy created FLINK-39843:
------------------------------
Summary: Support Oracle CDC streaming with the XStream adapter
Key: FLINK-39843
URL: https://issues.apache.org/jira/browse/FLINK-39843
Project: Flink
Issue Type: New Feature
Components: Flink CDC
Reporter: tianfy
Oracle CDC should support Debezium's XStream adapter in addition to LogMiner
for streaming changes.
XStream is required in some Oracle deployments where LogMiner is unavailable or
not preferred. The connector needs Oracle-specific integration for XStream
streaming, including XStream dependencies, stream source execution, LCR
handling, offset advancement, and processed low watermark commit behavior.
Expected behavior:
* support configuring the Oracle CDC source with the XStream adapter
* read streaming changes from Oracle XStream
* advance stream offsets even when no user-level event is emitted for captured
tables
* commit processed low watermark only when the stream split is safe to commit,
especially when newly added table scanning can suspend and recreate the stream
split
* include unit coverage for XStream stream source behavior and processed offset
commit timing
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
