Apache NiFi - 自定义处理器

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

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

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

• 添加名为M2_HOME的环境变量，并将值设置为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、version、package、artifactBaseName等

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

  • nifi-<artifactBaseName>-processors

  • nifi-<artifactBaseName>-nar

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

mvn install eclipse:eclipse

• 打开 eclipse 并从文件菜单中选择导入。

• 然后选择"现有项目放入工作区"并从 eclipse 中的 nifi-<artifactBaseName>-processors 目录添加项目。

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

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

mvn clean install

• 将在 nifi-<artifactBaseName>-nar/target 目录中创建 NAR 文件。

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

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

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