java - 具有 Spring 支持的 Apache Nifi 自定义处理器

标签 java spring apache-nifi

我正在创建一个自定义 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/

相关文章:

amazon-web-services - 使用 ECS 和外部 Zookeeper 的 AWS 上的 NiFi 集群

java - 用正则表达式中的另一组字符(成对)替换一组字符 : "&", "&amp;" "<"、 "<"等

java - 简单计数器中的 android 清除按钮

java - 具有良好 Java 支持的通用构建工具?

spring - 为什么 Spring Boot 启动器依赖项被设计为与 Maven 传递依赖机制的既定意图相反?

java - 如何使用 spring boot 应用程序绕过或跳过 Mockito 中的自定义过滤器

ssl - Curl:如何处理 NSS 错误 -8156?

java - 如何使用 Java 8 库将 UTC DateTime 转换为另一个时区?

java - org.springframework.beans.factory.BeanCreationException : Error creating bean with name 'playerDAOImpl' : Injection of autowired dependencies failed

apache-spark - 如何在 NiFi 中从 GetFilesProcessor 读取文件