Как получить количество узлов кластера в функции onTrigger во время выполнения?

Question

У меня есть кластер nifi с 6 узлами, и я хочу сделать некоторый баланс нагрузки в функции onTrigger моего собственного процессора:

@Override
public void onTrigger(ProcessContext context, final ProcessSession session) throws ProcessException {

}

Как я могу получить количество узлов в этой функции?

Answer 1

Вы не должны делать балансировку нагрузки в процессоре. Задача процессора состоит в том, чтобы взять один или несколько потоковых файлов, оперировать ими и создать один или несколько потоковых файлов.

Существуют встроенные механизмы для балансировки нагрузки в кластере:

https://blogs.apache.org/nifi/entry/load-balancing-across-the-cluster