I want to retry my flow file if it has some error for 24 hours , retry should will happen every hours . if the file is there in the flow for more then 24 hours it should be removed . iam trying achieve same by using update attribute processors , routeOnAttribute processor and taking help of expression language . Still iam not able to achieve it. these are the expression I am using to check elapsed time and received Time of flow file in routeOnAttribute  processor but its going to unmatched relation every time -  these values are for testing pursose - elapsed_time = ${now():toNumber():minus(${queuedtimestamp:toNumber()}):divide(60000):gt(10)} receivedTime= ${now():toNumber():minus(${receivedTime:toDate("yyyy-MM-dd HH:mm:ss"):toNumber()}):gt(180000)}   NOTE: retryFlowFile processor in not available as my nifi version is old   Please suggest better approach to do so . ... View more

Hi ,  I have a publish kafka processor where iam having a self loop and flowfile expiration time for that loop is 1 hours , if some file is there for more then 1 hour it will get removed.  i want to print log message (e.g. dropping the flow file) after every flow file is removed from queue after getting expired.   This is the flow - ... View more