Is there a way to convert JSON to Protobuf in NIFI?

Question

Im attempting to implement an MQTT dataflow which requires the final delivery to be sent using sparkplug specifications.

However, i am unable to find a way to convert the contents of the flowfile to be in a protobuf format

Is there a way to do this conversion?

Hope you have proto definition? Or maybe generated or compiled java code for this proto? I think you could use executegroovyscript. But need more details to help you. — daggett, Dec 17 '20 at 12:34

score 2 · Accepted Answer · answered Dec 21 '20 at 22:23

You have two options :

The "dirty way" by using the ExecuteScript processor (using your preferred language groovy for e.g) and implementing something equivalent to that
The cleanest way which is implement your own custom processor, you can start by using this one https://github.com/whiver/nifi-protobuf-processor and see if that fits your need.

1 Answers1