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)