[ https://issues.apache.org/jira/browse/FLINK-37156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17914529#comment-17914529 ]
yux commented on FLINK-37156: ----------------------------- Hi Cheng, Thanks for reporting this! There are already some discussions have been made in FLINK-36794 and a prototype implementation at [https://github.com/apache/flink-cdc/pull/3844.] Considering this change is widely affected, initiating a discussion thread in mailing list would be nice. > A Flink pipeline supports collecting data once and writing it to multiple > sinks. > -------------------------------------------------------------------------------- > > Key: FLINK-37156 > URL: https://issues.apache.org/jira/browse/FLINK-37156 > Project: Flink > Issue Type: New Feature > Affects Versions: cdc-3.3.0 > Reporter: cheng qian > Priority: Major > > Is there any plan in the community to support the scenario of multiple sinks? > We want to synchronize data from a MySQL database to StarRocks, Paimon, and > Kafka. Currently, we need to create three Pipelines, which triples the I/O > load on the MySQL database. We envision defining three sinks within a single > Pipeline, enabling data to be collected once and written to three different > downstream systems. -- This message was sent by Atlassian Jira (v8.20.10#820010)