我在 Nifi 中创建模板,然后在 Kylo 中导入它们。每个模板都特定于我的业务用例,它们由多个 (30+) Nifi 处理器组成。
为了我的单元测试和一些理智,我将每个处理器的错误关系转发到单独的 logAttribute。
但是当我将此模板导入 Kylo 时,即使流程失败,Kylo 也不会将其视为错误,因为所有错误都会记录到 logArribute。
现在我可以将模板中每个处理器的错误关系转发到单个 logArribute。然后将该流转发到 Kylo 的错误端口。
这是一个正确的解决方案吗?如果没有,其他开发人员会做什么?我在想,Nifi 应该有某种 SINK 处理器,我可以在其中转储我所有的错误关系。
请评论。
谢谢,