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