I'm new to ElasticSearch, only been enjoying it as the backend of the Kibana instance running in production.
I have a new requirement, I have to parse application logs in real time, until now via bufferedReader.readLine() in a loop on the log files themselves.
In the new scenario the applications are containers in Openshift that are forwarding logs to Fluentd and Fluentd is sending them to ES, so I'd like to just swap out the bufferedReader.readLine() of my previous parsing application in favour of an API call exposed by the ES Java SDK.
Is there something similar that would fit my requirement?
Thank you everyone,