Я создаю шаблон в Nifi, а затем импортирую их в Kylo. Каждый шаблон специфичен для моего бизнес-сценария и состоит из нескольких (более 30) процессоров Nifi.
для моего модульного тестирования и для здравого смысла я пересылаю отношение ошибок каждого процессора в отдельный logAttribute.
но когда я импортирую этот шаблон в Kylo, даже когда поток не удается, Kylo не воспринимает его как ошибку, так как все ошибки собираются в logArribute.
Теперь я могу переслать отношение ошибок каждого процессора в шаблоне к одному logArribute. А затем перенаправьте этот поток на порт ошибки Kylo.
Это правильное решение? если нет, то что делают другие разработчики? Я думаю, у Nifi должен быть какой-то процессор SINK, куда я сбрасываю все свои ошибки.
Пожалуйста, прокомментируйте.
Спасибо