Насколько мне известно, NiFi не имеет встроенной интеграции с библиотекой / протоколом nanomsg. Это, вероятно, потребует написания собственного процессора, способного потреблять пакеты nanomsg с использованием типов паттернов / сокетов nanomsg PUBSUB.
Можно использовать существующие процессоры, такие как Consume* процессоры (ConsumeKafka, ConsumeJMS), в качестве примера / руководства о том, как написать процессор, который принимает сообщения из темы / очереди, следующей за pub / sub шаблон.
Затем вы захотите преобразовать полезную нагрузку из двоичного файла Flatbuffers в формат, который можно вставить в нужную базу данных. Опять же, пользовательский процессор, использующий код, сгенерированный из вашей схемы Flatbuffer, вероятно, будет правильным подходом для этого.
Как вы упоминаете, это также может быть достигнуто с помощью простой программы. Если вы написали эту программу на Java (используя Java Nanomsg и библиотеки плоских буферов) в качестве прототипа / доказательства концепции, то в будущем она может быть преобразована в один или несколько пользовательских процессоров NiFi, если вы захотите перейти на NiFi.