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, > > > >
