I was looking for a server sent event (SSE) client in Apache NiFi, however, I couldn't find any ready processor that can do that.
I started implementing an SSE client using Python script and used ExecuteCommand processor to run this script. However, the script needs to be terminated in order to send the processor output to the next step through STDOUT. (ie. I can't use an infinite Loop "While True:" to listen to the SSE server and output the consumed events on stream).
Is there any ideas to implement the SSE client in NiFi such that consumed events are processed one by one to the next processors in real-time?