[jira] [Assigned] (FLINK-23977) Add Support for Dynamic Elastic Cluster/Index Routing

["Fabian Paul (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-23977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Fabian Paul reassigned FLINK-23977:
-----------------------------------

    Assignee: Rion Williams

> Add Support for Dynamic Elastic Cluster/Index Routing
> -----------------------------------------------------
>
>                 Key: FLINK-23977
>                 URL: https://issues.apache.org/jira/browse/FLINK-23977
>             Project: Flink
>          Issue Type: Improvement
>          Components: Connectors / ElasticSearch
>            Reporter: Rion Williams
>            Assignee: Rion Williams
>            Priority: Major
>              Labels: elasticsearch
>
> Currently only index-level dynamic routing is supported within the Elasticsearch connector, which can be problematic if information such as the host of the cluster (e.g. HttpHosts) is not known until run-time. 
> The idea behind this ticket would be to implement a wrapper that would allow Elasticsearch sink instances to be created at run time and stored within an in-memory cache (i.e. HashMap) using a key-value association where the key represents a deterministically unique "route" and the value is the sink to which all items with a given key are written.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)