Rion Williams created FLINK-24493:
-------------------------------------

             Summary: Introduce DemultiplexingSink
                 Key: FLINK-24493
                 URL: https://issues.apache.org/jira/browse/FLINK-24493
             Project: Flink
          Issue Type: New Feature
          Components: Connectors / Common
            Reporter: Rion Williams


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)

Reply via email to