Apache Iggy Trigger

Apache Iggy Trigger
Certified
Trigger on polled Apache Iggy messages

Polls an Apache Iggy stream and topic on a schedule (default every 60s) and starts one execution per batch. Only supports strategy: Next and autoCommit: true to prevent duplicate executions across scheduled evaluations.

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

Examples

Poll an Apache Iggy topic on a schedule and trigger an execution when messages arrive

yaml
id: iggy_trigger
namespace: company.team
triggers:
  - id: watch
    type: io.kestra.plugin.iggy.Trigger
    host: iggy.example.com
    port: 8090
    username: "{{ secret('IGGY_USERNAME') }}"
    password: "{{ secret('IGGY_PASSWORD') }}"
    stream: orders
    topic: created
    maxRecords: 10
tasks:
  - id: process
    type: io.kestra.plugin.core.log.Log
    message: "Consumed {{ trigger.messagesCount }} messages from URI {{ trigger.uri }}"

Properties

host *string

Server host

Hostname or IP address of the Apache Iggy server.

stream *string

Stream identifier or name

Name or ID of the Apache Iggy stream to consume messages from.

topic *string

Topic identifier or name

Name or ID of the Apache Iggy topic to consume messages from.

allowConcurrent boolean

Defaultfalse

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

autoCommit booleanstring

Defaulttrue

Auto-commit offsets

Whether to automatically commit the consumer offset of processed messages. Defaults to true.

batchSize integerstring

Default50

Batch size

Maximum messages fetched per poll. Must be greater than or equal to 1. Defaults to 50.

consumerId string

Default1

Consumer ID or Name

Identifier of the consumer used to track offsets. Defaults to '1'.

interval string

DefaultPT1M

Formatduration

Evaluation interval

Interval between trigger polling evaluations. Defaults to 60s.

maxDuration string

Maximum polling duration

Maximum duration to poll before stopping execution.

maxRecords integerstring

Maximum records to consume

Optional cap on total messages before stopping.

offset integerstring

Offset or Timestamp value

Starting offset or timestamp when strategy is Offset or Timestamp.

partitionId integerstring

Partition ID

Optional partition ID to consume from.

password string

Authentication password

Password for authentication.

pollDuration string

DefaultPT1S

Poll interval duration

Wait duration between empty poll attempts. Defaults to PT1S.

port integerstring

Default8090

Server port

Port of the Apache Iggy server. Defaults to 8090 for TCP and 3000 for HTTP.

stopAfter array

SubTypestring

Possible Values

CREATEDSUBMITTEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPEDBREAKPOINTRESUBMITTED

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

strategy string

DefaultNext

Possible Values

OffsetTimestampFirstLastNext

Polling strategy kind

Polling strategy: Offset, Timestamp, First, Last, or Next. Defaults to Next.

tls booleanstring

Defaultfalse

Use TLS

Whether to enable TLS encryption for the connection. Defaults to false.

token string

Personal access token

Personal access token (PAT) for token-based authentication.

transport string

DefaultTCP

Possible Values

TCPHTTP

Transport protocol

Transport protocol to use: TCP (default) or HTTP.

username string

Authentication username

Username for 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

messagesCount integer

Messages consumed count

Total number of messages consumed during this task execution.

uri string

Formaturi

Output file URI

Kestra internal storage URI of the file containing consumed messages.