Support Questions
Find answers, ask questions, and share your expertise

NiFi: Split a JSON into multiple on attribute

New Contributor

Below is my current dataflow design:

ConsumeKafkaRecord
SplitJson
EvaluateJsonPath
RouteOnAttribute
ExecuteScript
PutFile


My current requirement is to split a record into multiple records based on an attributes value.
Example, one JSON message/record into multiple JSON records(2 or 3 or just keep the original record).

I'm able to do this inside the `ExecuteScript processor` but would like to know if there is a better way of splitting a json record that is coming out of kafka into `multiple json` records.

0 REPLIES 0