Вы пытаетесь сбалансировать нагрузку взаимодействия с пользовательским интерфейсом или определенного процессора/источника ввода? Благодаря кластеризации с нулевым мастером (ZMC) от NiFi, доступной в версии 1.0.0+, вы можете подключаться к пользовательскому интерфейсу любого подключенного узла, отслеживать и изменять поток. Если вы пытаетесь сбалансировать нагрузку на входные данные, я бы посоветовал либо иметь процессор с единой точкой входа, который работает на основном узле (см. отрывок ниже), а затем распределяет данные по всему кластеру, либо если вам действительно нужна балансировка нагрузки немедленно для производительности, возможно, настроив что-то вроде HAProxy или другого внешнего балансировщика нагрузки (даже циклического DNS) и указывая на все доступные узлы.

Если вы пытаетесь сбалансировать нагрузку в кластере, Группы удаленных процессов, которые позволяют осуществлять передачу между узлами, автоматически балансирует данные между доступными узлами NiFi.

Из Руководства администратора NiFi.

Первичный узел: в каждом кластере есть один первичный узел. На этом узле можно запускать изолированные процессоры (см. ниже). ZooKeeper используется для автоматического выбора основного узла. Если этот узел отключится от кластера по какой-либо причине, будет автоматически выбран новый основной узел. Пользователи могут определить, какой узел в настоящее время выбран в качестве основного узла, посмотрев на страницу управления кластером пользовательского интерфейса.

Изолированные процессоры: в кластере NiFi один и тот же поток данных выполняется на всех узлах. В результате каждый компонент в потоке выполняется на каждом узле. Однако могут быть случаи, когда DFM не хочет, чтобы каждый процессор работал на каждом узле. Самый распространенный случай — это использование процессора, который взаимодействует с внешней службой по плохо масштабируемому протоколу. Например, процессор GetSFTP извлекает из удаленного каталога, и если процессор GetSFTP работает на каждом узле в кластере, пытается одновременно извлекать данные из одного и того же удаленного каталога, могут возникнуть условия гонки. Таким образом, DFM может настроить GetSFTP на основном узле для работы в изоляции, что означает, что он работает только на этом узле. Он может извлекать данные и — при правильной конфигурации потока данных — распределять их нагрузку между остальными узлами в кластере. Обратите внимание, что, хотя эта функция существует, также очень часто просто используют автономный экземпляр NiFi для извлечения данных и передачи их в кластер. Это просто зависит от доступных ресурсов и от того, как администратор решает настроить кластер.