Hi all,
I have a requirement where I get xml documents from Kafka. Each xml document contains 5 arrays. Each array should go into a specific table in Sql Server. I am thinking of converting xml into json and use ConvertJsonToSql processor. (Please provide a better approach). As ConvertJsonToSql processor takes only one array, I am looking for a way to split the source document into 5 plain documents (one for each array) and use 5 ConvertJsonToSql processors. I am not clear how the transactions work in Nifi. All inserts into these 5 tables should happen in a single transaction for a document. I have been struggling to get clarity on approach. Can you please help me?
Thanks in advance.
Subrahmanya
