[ https://issues.apache.org/jira/browse/FLINK-24493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Rion Williams updated FLINK-24493: ---------------------------------- Summary: Introduce DemultiplexingSink to Support Dynamic Sink Routing (was: Introduce DemultiplexingSink) > Introduce DemultiplexingSink to Support Dynamic Sink Routing > ------------------------------------------------------------ > > Key: FLINK-24493 > URL: https://issues.apache.org/jira/browse/FLINK-24493 > Project: Flink > Issue Type: New Feature > Components: Connectors / Common > Reporter: Rion Williams > Priority: Major > > Recently, FLINK-23977 attempted to introduce an approach to supporting > dynamic routing for the Elasticsearch sink, however during some discussion > within [the pull request|https://github.com/apache/flink/pull/17061], the > idea was introduced to create a more generic approach. > The idea being that we could introduce a common DemultiplexingSink and > related interface for handling routing to any number of existing sinks > similar to the implementation mentioned in FLINK-23977 to the common > connectors directory. -- This message was sent by Atlassian Jira (v8.3.4#803005)