@Steven Matison Could you please elaborate more ? Right now I am using TailFile--->RouteOnContent-->PutEmail. So in this flow i am able to get the only errors from log file in attached file in an email. My question is how can I capture those error message and put as the message of PutEmail processor ? ... View more

No I have been using the plain getFile which is having input as a simple folder and we are not doing any regex on those files. FYI.... In my entire workflow all processors are behaving the same. ... View more

I am using GetFile processor.. ... View more

Yeah as you guys said I did restart the instance it worked but If I stop the processor and start again then same issue. Should I restart nifi Instance every time whenever processor stops and starts since we are dev phase we have to stop and start the processor ? ... View more

Thanks for quick response @Matt Burgess Its not disappearing since long time. Is there anyway I could kill the threads forcefully and if not Could you let me know what will be the solution to overcome this ? Thanks Jasti. ... View more

Thanks for response. Small correction.. From custom code the message is gonna publish to kafka queue from there I am picking the JSON message to pass to EvaluateJsonPath processor. the EvaluateJsonPath has now two values one is source path and one is destination path. As you said you can use FetchS3Object to get the file from S3, how should I pass the source path to FetchS3Object processor and then how should I pass the destination path to PutFile processor? Could you explain me briefly ? Right now my flow is like attached screen shot. PFA... ... View more

yup got it thanks.By mistake I have unchecked Enable SSL checkbox in NIFI config after checking back I could see them . Thanks @Matt Clarke ... View more