Following your feedback, I looked at the ConsumeKafkaRecord and I think that yes you're right I could apply the following Flow: ConsumeKafkaRecord(ScriptedReader, CSVWriter) => MergeContent => UpdateAttributes => PutFile.

1/ In the ConsumeKafkaRecord, I'd like to use a ScriptedReader to convert and modify the json message and a CSVWriter to write the new message.

2/ MergeContent to merge the stream files.

3/ UpdateAttributes to change the file name.

4/ PutFile to write the file

The only problem is the header I want to write to the CSV file, as I only want one header.

Do you agree with this flow?

Thanks a lot.