我正在创建一个自定义 NIFI 处理器(目前是 NIFI 自己的 emailProcessor 的精简版本)。
如果我可以使用 Spring 的依赖注入(inject),那就太好了。 例如: EmailService bean 负责发送邮件。 在我的处理器中,EmailService 应该是自动连接的。
如何配置?
最佳答案
Apache NiFi 处理器本身与 Spring 没有任何关系。您必须在处理器的 @OnScheduled 方法中创建一个 ApplicationContext,然后获取稍后调用 onTigger 时要使用的 bean。我不认为你能够直接 @Autowire 进入处理器,因为处理器本身是由 NiFi 框架管理的,而不是 Spring bean。
关于java - 具有 Spring 支持的 Apache Nifi 自定义处理器,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/43719369/