nifi version iam using is old Powered by Apache NiFi - Version 1.8.0.3.3.0.0-165 , i have developed the same solution using retryFlowFile processor , but its working in my other environment due to old nifi version , so i need to have same implementation in that too . @MattWho even retry relation is not there in this version. i was trying to achieve this by expression language , but that is also not working.     ... View more

control rate processor is nor working  ... View more

disconnect and reconnect again this functionality i want to achieve with Publish kafka processor . ConsumerKafka will consumer continuously . ... View more

consuming from nifi is fine that i want to be continuous , i want to terminate connection for publish kafka  processor , when there is no new message consumed by consumeKafka processor for more then 5 minutes , i want to terminate connection with publish kafka as my consumer kafka and producer kafka are different . as soon as my consumer kafka consumer some message , i want connection to be established again with producer kafka ... View more

Thanks @SAMSAL  its working , but iam not bale to understand the settings . My requirement is , my max queue size will be 250 requests and i wanted them to get retried till 24 hours , every hour (every 1 hours till 24 hours) . once a flow file has completed 24 hours in queue i want it to get expired and i will drop it , by connecting it to a log message processor . can you please help on these settings ????  ... View more

kafka\.topic  , i tried adding this  , but it did not work . I checked kafka headers too there also nothing being printed in haeder. ... View more

kafka.topic is a key , it will have value of a kafka topic name e.g abc_xyz  . this value will keep on depending from where iam consuming the meassge , from which topic . my requirement is to send the topic from where i consumed as header to the topic where iam publishing it . how can i do that ?? ... View more