Hi, Are you using datastream api or table api？If you are using the table api, you can use the connector by executing sql[1]. If you are using the datastream api, there is really no es connector api provided, you need to write python wrapper code, but the wrapper code is very simple. The underlying code takes use of py4j to call the java api of es connector. For details, you can refer to the wrapper code in kafka or pulsar[2].
[1] https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/connectors/table/overview/ [2] https://github.com/apache/flink/blob/master/flink-python/pyflink/datastream/connectors.py Best, Xingbo Sandeep Sharat <sandeepsha...@gmail.com> 于2022年3月29日周二 20:51写道： > Hello Everyone, > > I have been working on a streaming application using elasticsearch as the > sink. I had achieved it using the java api quite easily. But due to a > recent policy change we are moving towards the python api for flink, > however we were unable to find any python elastic search connectors for > flink. We were able to find support for the kafka connectors in python. > Does it mean that we have to write our own connectors in python to > make use of the flink-elasticsearch connector jar?.... > > Thanks in advance > -- > Thanks & Regards > Sandeep Sharat Kumar >
