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?

Answer 1

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.