You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/03/27 11:07:00 UTC

[jira] [Created] (FLINK-34952) Flink CDC pipeline supports SourceFunction

Hongshun Wang created FLINK-34952:
-------------------------------------

             Summary: Flink CDC pipeline supports SourceFunction 
                 Key: FLINK-34952
                 URL: https://issues.apache.org/jira/browse/FLINK-34952
             Project: Flink
          Issue Type: Improvement
          Components: Flink CDC
            Reporter: Hongshun Wang
             Fix For: cdc-3.1.0


Though current Flink CDC pipeline define com.ververica.cdc.common.sink.
FlinkSinkFunctionProvider to to provide a Flink SinkFunction for writing events to external systems. However, com.ververica.cdc.runtime.operators.sink.DataSinkWriterOperator don't support SouceFunction, which means sink implement SinkFunction cannot use CDC pipeline.
Why not support  SourceFunction in Flink CDC pipeline ?



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