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)