Apache NiFi Trigger

Apache NiFi Trigger
Certified
Trigger workflow executions on Apache NiFi Bulletin Board events

Periodically polls the NiFi Bulletin Board and triggers workflow executions when new bulletins matching the configured level are detected.

yaml
type: io.kestra.plugin.nifi.Trigger

Examples

Poll Apache NiFi Bulletin Board for ERROR events every minute

yaml
id: nifi_error_alert
namespace: company.team

tasks:
  - id: log_bulletins
    type: io.kestra.plugin.core.log.Log
    message: "Discovered {{ trigger.bulletins | length }} NiFi errors: {{ trigger.bulletins }}"

triggers:
  - id: nifi_bulletin_trigger
    type: io.kestra.plugin.nifi.Trigger
    url: "https://localhost:8443"
    username: "nifi-admin"
    password: "{{ secret('NIFI_PASSWORD') }}"
    sslVerify: false
    level: "ERROR"
    interval: PT1M

Properties

url *string

The Apache NiFi base URL

The fully qualified URL pointing to your Apache NiFi cluster or instance (e.g., https://localhost: 8443 or http://localhost: 8080).

allowConcurrent boolean

Defaultfalse

Specifies whether a trigger is allowed to start a new execution even if a previous run is still in progress.

interval string

DefaultPT1M

Formatduration

Interval between polling checks

The duration between each poll to the NiFi Bulletin Board. Defaults to 1 minute (PT1M). Note that NiFi retains at most 5 bulletins per component for up to 5 minutes, so higher polling intervals may miss bulletins under heavy activity.

level string

DefaultERROR

Possible Values

DEBUGINFOWARNINGERROR

Bulletin level to filter

The bulletin level to filter on: DEBUG, INFO, WARNING, or ERROR. WARN is accepted as an alias for WARNING. Defaults to 'ERROR'.

password string

The password for NiFi authentication

sslVerify booleanstring

Defaulttrue

Whether to verify SSL certificates

Set to false to disable SSL verification (e.g., for self-signed certificates).

stopAfter array

SubTypestring

Possible Values

CREATEDSUBMITTEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPEDBREAKPOINTRESUBMITTED

List of execution states after which a trigger should be stopped (a.k.a. disabled).

username string

The username for NiFi authentication

when string

Defaulttrue

A condition that determines whether the trigger should run.

A Pebble expression evaluated at trigger time. The trigger fires only when the expression evaluates to a truthy value (true, a non-empty string, a non-zero number). Use this to gate trigger execution on dynamic runtime values such as execution labels, flow variables, or environment conditions.

Outputs

bulletins array

SubTypeobject

The list of bulletins discovered matching the criteria

List of NiFi bulletin objects matching the configured level since the last watermark.