So the use case that I want to implement is some requests will be landing on my NIFI in XML format and then I want to control its rate and then pick the necessary inputs from the XML and then differentiate based on a report number and use rate limit on the the defined report numbers and then further a rate limit on a article number which I pick from the XML and then I call an API and send the response back the initial response now the issue is I am using control rate processor to hold the requests to 5 per second but with hold flowfile config as I cannot fail the request directly but also I want to fail the queueing requests after 5 second and with a specific status code and also I want to log on which of the three control rate failed the request. Any help how this flow can be created? And also monitor how many requests landed in the server per sec how many succeeded and how many failed per second.   ... View more

I have a three node NIFI setup and I want to establish a TCP connection channel with an external system to send and recieve data on a single channel how can that be achieved ? ... View more

I am using the GetMongo processor to query a mongoDB for a particular key value pair and if the data is found then I want to log that But if the data is not found in the DB then I want to use the same key value pair (already present in the attributes of each flow file) that is failed and input into the next processor how can I approach this issue. ... View more

I want to split this json {"id": "652fbf430f1f3f30a3111f11,652fbf430f1f3f30a3333f11", "Qid": 123} into {"id": "652fbf430f1f3f30a3111f11", "Qid": 123} and {"id": "652fbf430f1f3f30a3333f11","Qid": 123} using Apache Nifi in the above example we have two id values there can be multiple values as well then I want to add these id values to the attribute of the two flow files that are created from the split JSONs. ... View more

I have to make a flow where I want to check that two Mongo DBs are in sync so everyday I have to compare the count of records that are being inserted into both the DBs if there is a discrepancy I want to transfer the records from the main DB to the DB which doesn't have it. Both DBs have a created AT key which has the date when the record was added. I want to achieve this through apache NIFI.   ... View more

I want to execute export command to take the PSQL dump of the database and transfer it using NIFI and the execute the import command at the destination db. can anyone provide a flow to do so ? ... View more

Embedded zookeeper is failing to start while setting up a three node cluster for NIFI. The error message indicates that there is an issue with starting the embedded Zookeeper server while starting NiFi on your three-node cluster. The specific error causing the problem is "Address already in use," which suggests that the port required by Zookeeper is already occupied by another process. How can I solve this issue?     ... View more