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)
