Hi, Fidea. Currently, elasticsearch is not supported to be used as a source. You can see the jira[1] for more details. You can also cherry pick this pr[2] to your own branch and build a custom elasticsearch connector to use it directly.
[1] https://issues.apache.org/jira/browse/FLINK-25568 [2] https://github.com/apache/flink-connector-elasticsearch/pull/62 -- Best！ Xuyang At 2024-03-12 18:28:46, "Fidea Lidea" <lideafidea...@gmail.com> wrote: Hi , I am trying to read data from elasticsearch & store in a stream. Could you please share a few examples to read/get all data from Elasticsearch using java. Thanks,
