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