json - 有没有办法在 NIFI 中将 JSON 转换为 Protobuf？

Question

我试图实现一个 MQTT 数据流，该数据流需要使​​用火花塞规范发送最终交付。

但是，我无法找到将流文件的内容转换为 protobuf 格式的方法

有没有办法进行这种转换？

标签： jsonmqttapache-nifiprotobuf-java

Answer 1

你有两个选择：

• 通过使用ExecuteScript 处理器（例如使用您喜欢的语言 groovy）并实现与之等效的东西的“肮脏方式”

• 实现您自己的自定义处理器的最简洁方法，您可以从使用这个https://github.com/whiver/nifi-protobuf-processor开始，看看它是否符合您的需要。