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,
