Apache NiFi是一个开源平台，为开发人员提供了将其自定义处理器添加到NiFi库中的选项。请按照以下步骤创建自定义处理器。

• 从下面给出的链接下载Maven最新版本。

  https://maven.apache.org/download.cgi

• 添加一个名为M2_HOME的环境变量，并将value设置为maven的安装目录。

• 从下面的链接下载Eclipse IDE。

  https://www.eclipse.org/downloads/download.php

• 打开命令提示符并执行Maven Archetype命令。

> mvn archetype:generate

• 在原型项目中搜索nifi类型。

• 选择org.apache.nifi：nifi-processor-bundle-archetype项目。

• 然后从版本列表中选择最新版本，即本教程的1.7.1。

• 输入groupId，artifactId，版本，程序包和artifactBaseName等。

• 然后将创建一个必须具有目录的Maven项目。

  • nifi- -处理器

  • nifi- -nar

• 在nifi- -processors目录中运行以下命令，将项目添加到eclipse中。

mvn install eclipse:eclipse

• 打开eclipse，然后从文件菜单中选择导入。

• 然后选择“将现有项目放入工作区”，然后从eclipse中的nifi- -processors目录中添加项目。

• 将代码添加到public void onTrigger(ProcessContext context，ProcessSession session)函数，该函数在计划运行处理器的任何时候运行。

• 然后通过运行以下提到的命令将代码打包到NAR文件中。

mvn clean install

• NAR文件将在nifi- -nar / target目录。

• 将NAR文件复制到Apache NiFi的lib文件夹中，然后重新启动NiFi。

• 成功重启NiFi之后，检查新自定义处理器的处理器列表。

• 如有任何错误，请检查./logs/nifi.log文件。