Apache Nifi 自定义处理器对另一个处理器的依赖

Apache Nifi Custom Processor dependency on another processor

根据我的要求,我需要创建一个 Nifi 自定义处理器,它将构建消息然后写入 Splunk。

我在下面关注 link 以创建自定义处理器,但不清楚如何在自定义处理器代码中使用 invokeHttpProcessor/putSplunk 处理器。任何建议表示赞赏

https://help.syncfusion.com/data-integration/how-to/create-a-custom-processor

一般来说,像 InvokeHttp 和 PutSplunk 这样的实际处理器实现并不意味着按原样进行子类化,如果有代码可以在处理器之间重用,请随时与社区联系(通过 mailing list 例如),我们可以讨论将此类代码移出到 API.

与此同时,我不确定将实现 NAR 作为自定义处理器 NAR 的父级是否可行,但您可以尝试这样做,它可能会让您对实现进行子类化,但不推荐这样做.

另一种方法是从您想要的处理器中复制代码,然后直接在您的自定义处理器中使用该复制代码。当然有一些可维护性的变化,但是如果你封装你的自定义处理器远离重复的 NiFi 处理器,你只需要留意对 NiFi 处理器所做的任何更改并相应地更新你的副本。