UDP RealtimeTrigger

UDP RealtimeTrigger
Certified
Trigger on incoming UDP messages

Listens on a UDP port and fires immediately for each received datagram. Default bind 0.0.0.0, buffer 1024 bytes, UTF-8 decoding.

yaml
type: io.kestra.plugin.fs.udp.RealtimeTrigger

Examples

Trigger a flow whenever a UDP datagram is received.

yaml
id: udp_listener
namespace: dev

triggers:
  - id: udp_incoming
    type: io.kestra.plugin.fs.udp.RealtimeTrigger
    host: 0.0.0.0
    port: 8091

tasks:
  - id: log_message
    type: io.kestra.plugin.core.log.Log
    message: "📩 Received UDP: {{ trigger.payload }} from {{ trigger.sourceIp }}:{{ trigger.sourcePort }}"

Installation

Our standard Docker images already include this plugin. If you use a -slim image or another setup, install it with the following command:

kestractl plugins get io.kestra.plugin:plugin-fs --compatible-for $KESTRA_VERSION

For kestractl, use your Kestra version with --compatible-for, or specify an exact plugin version.

For Kestra CLI, replace LATEST with a specific version or version range to pin the plugin version.

Properties

port *integerstring

UDP port to listen on

allowConcurrent boolean

Defaultfalse

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

bufferSize integerstring

Default1024

Buffer size in bytes

encoding string

DefaultUTF-8

Encoding for incoming data

host string

Default0.0.0.0

Interface to bind

stopAfter array

SubTypestring

Possible Values

CREATEDSUBMITTEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPEDBREAKPOINTRESUBMITTED

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

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

payload string

The received UDP payload

sourceIp string

The IP address of the sender

sourcePort integer

The port of the sender

timestamp string

Formatdate-time

The timestamp when the message was received