I have just started learning NiFi.i am stuck at one scenario. I need your help to proceed on the same.
I have XML data in Kafka message.this message is composed of records which has to be either inserted or updated/deleted into rdbms system based on flag present in the XML data.
Now the problem is, suppose we have 10 records in XML. First 7 records are with the insert flag,next 2 with update and the last one with the delete flag. I want to execute all insertion first, then updates and finally the delete operation.
Could you please help me with approach and NiFi processors to achieve this functionality.