Apache Iggy RealtimeTrigger
CertifiedTrigger on real-time Apache Iggy messages
Apache Iggy RealtimeTrigger
Trigger on real-time Apache Iggy messages
Reacts to Apache Iggy messages in real-time by creating one execution per message as soon as it arrives on the stream and topic. Designed for UTF-8 text and JSON payloads; arbitrary binary payloads are not supported. Consumer offsets are committed after the message is emitted downstream when autoCommit is enabled.
type: io.kestra.plugin.iggy.RealtimeTriggerExamples
Consume Apache Iggy messages in real-time and create an execution per message
id: iggy_realtime_trigger
namespace: company.team
triggers:
- id: realtime_watch
type: io.kestra.plugin.iggy.RealtimeTrigger
host: iggy.example.com
port: 8090
username: "{{ secret('IGGY_USERNAME') }}"
password: "{{ secret('IGGY_PASSWORD') }}"
stream: telemetry
topic: sensors
consumerId: "1"
strategy: Next
tasks:
- id: log_message
type: io.kestra.plugin.core.log.Log
message: "Received sensor data: {{ trigger.payload }} (id={{ trigger.id }}, offset={{ trigger.offset }})"
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
falseSpecifies whether a trigger is allowed to start a new execution even if a previous run is still in progress.
autoCommit booleanstring
trueAuto-commit offsets
Whether to automatically commit the consumer offset of processed messages. Defaults to true.
batchSize integerstring
50Batch size
Maximum messages fetched per poll. Must be greater than or equal to 1. Defaults to 50.
consumerId string
1Consumer ID or Name
Identifier of the consumer used to track offsets. Defaults to '1'.
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
PT1SPoll interval duration
Wait duration between empty poll attempts. Defaults to PT1S.
port integerstring
8090Server port
Port of the Apache Iggy server. Defaults to 8090 for TCP and 3000 for HTTP.
stopAfter array
CREATEDSUBMITTEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPEDBREAKPOINTRESUBMITTEDList of execution states after which a trigger should be stopped (a.k.a. disabled).
strategy string
NextOffsetTimestampFirstLastNextPolling strategy kind
Polling strategy: Offset, Timestamp, First, Last, or Next. Defaults to Next.
tls booleanstring
falseUse 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
TCPTCPHTTPTransport protocol
Transport protocol to use: TCP (default) or HTTP.
username string
Authentication username
Username for authentication.
when string
trueA 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
headers object
Message headers
Headers associated with the consumed message.
id string
Message ID
Unique ID of the consumed message.
offset integer
Message offset
Offset of the message within the partition.
partitionId integer
Partition ID
Partition ID from which the message was consumed.
payload string
Message payload
Payload of the consumed message as a UTF-8 string. Designed for text and JSON payloads; arbitrary binary payloads are not supported.
stream string
Stream identifier
Stream from which the message was consumed.
timestamp string
date-timeMessage timestamp
Timestamp when the message was received by the broker.
topic string
Topic identifier
Topic from which the message was consumed.
