Hi, Nida. Can you explain more details about "unable to use it." ? Did you get an exception after using it?
-- Best! Xuyang 在 2024-03-21 21:14:53,"Fidea Lidea" <lideafidea...@gmail.com> 写道: Thank you Xuyang. I added the above flink-connector-elasticsearch dependency in my project. But I am unable to use it. Can you please share a few sample codes which are using this dependency? Thanks Nida On Tue, Mar 12, 2024 at 5:37 PM Xuyang <xyzhong...@163.com> wrote: 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,