Daishuyuan created FLINK-39976:
----------------------------------

             Summary: Flink cdc pipeline support db2 source pipeline connector
                 Key: FLINK-39976
                 URL: https://issues.apache.org/jira/browse/FLINK-39976
             Project: Flink
          Issue Type: Improvement
          Components: Flink CDC
            Reporter: Daishuyuan


* Motivation

Flink CDC already provides DB2 CDC source / incremental source support, but the 
pipeline connector side is still missing. This makes DB2 inconsistent with the 
other databases already supported by the pipeline framework, and prevents users 
from using DB2 CDC in the unified pipeline mode.

Existing related issue FLINK-34842 covers DB2 incremental source support, but 
it does not track the missing DB2 pipeline connector. There was also an old 
GitHub PR apache/flink-cdc#3450 for DB2 pipeline source support, but it was 
closed as stale and was not merged.

* What is proposed

This change adds a new DB2 pipeline connector module and integrates it into the 
pipeline connectors build, following the same style as the SQL Server pipeline 
connector task FLINK-39252.

The implementation should reuse the existing DB2 source connector capabilities 
where possible and provide the required pipeline connector factory, options, 
metadata handling, documentation, and tests so DB2 can be used in Flink CDC 
pipeline YAML mode.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to