Apache NiFi - Processador Personalizado

Apache NiFi é uma plataforma de código aberto e oferece aos desenvolvedores a opção de adicionar seu processador personalizado à biblioteca NiFi. Siga estas etapas para criar um processador personalizado.

Baixe a versão mais recente do Maven no link fornecido a seguir.

https://maven.apache.org/download.cgi
Adicione uma variável de ambiente chamada M2_HOME e defina o valor como o diretório de instalação do maven.
Faça download do Eclipse IDE no link abaixo.

https://www.eclipse.org/downloads/download.php
Abra o prompt de comando e execute o comando Maven Archetype.

> mvn archetype:generate

Pesquise o tipo nifi nos projetos de arquétipo.
Selecione org.apache.nifi: projeto nifi-processor-bundle-archetype.
Em seguida, na lista de versões, selecione a versão mais recente, ou seja, 1.7.1 para este tutorial.
Insira groupId, artifactId, versão, pacote e artifactBaseName etc.
Em seguida, um projeto maven será criado tendo como diretórios.
- nifi-<artifactBaseName>-processors
- nifi-<artifactBaseName>-nar
Execute o comando abaixo no diretório nifi- <artifactBaseName> -processors para adicionar o projeto no eclipse.

mvn install eclipse:eclipse

Abra o eclipse e selecione importar no menu de arquivo.
Em seguida, selecione “Projetos Existentes no espaço de trabalho” e adicione o projeto do diretório nifi- <artifactBaseName> -processors no eclipse.
Adicione seu código na função pública void onTrigger (ProcessContext context, ProcessSession session), que é executada sempre que um processador está programado para ser executado.
Em seguida, empacote o código em um arquivo NAR executando o comando mencionado abaixo.

mvn clean install

Um arquivo NAR será criado no nifi- -nar / diretório de destino.
Copie o arquivo NAR para a pasta lib do Apache NiFi e reinicie o NiFi.
Após o reinício bem-sucedido do NiFi, verifique a lista de processadores para o novo processador personalizado.
Para quaisquer erros, verifique o arquivo ./logs/nifi.log.