Subscribe | Kestra

Subscribe

Subscribe and buffer MQTT messages

yaml
type: "io.kestra.plugin.mqtt.Subscribe"

Examples

yaml
id: mqtt_subscribe
namespace: company.team

tasks:
  - id: subscribe
    type: io.kestra.plugin.mqtt.Subscribe
    server: tcp://localhost:1883
    clientId: kestraProducer
    qos: 1
    maxDuration: 30s
    topic:
      - kestra/sensors/cpu
      - kestra/sensors/mem
    serdeType: JSON
    maxRecords: 10

yaml
id: mqtt_subscribe
namespace: company.team

tasks:
  - id: subscribe
    type: io.kestra.plugin.mqtt.Subscribe
    server: ssl://localhost:8883
    clientId: kestraProducer
    qos: 2
    maxDuration: 1m
    topic:
      - kestra/sensors/cpu
      - kestra/sensors/mem
    crt: /home/path/to/ca.crt
    serdeType: JSON
    maxRecords: 10

Properties

clientId *string

server *string

topic *object

authMethod string

connectionTimeout string

crt string

httpsHostnameVerificationEnabled booleanstring

maxDuration string

maxRecords integerstring

mqttVersion string

DefaultV5

Possible Values

V3V5

password string

qos integerstring

Default1

serdeType string

DefaultJSON

Possible Values

STRINGJSONBYTES

username string

Outputs

messagesCount integer

uri string

Formaturi

Metrics

duration timer

records counter

Apache Cassandra

Tasks that integrate Apache Cassandra into Kestra workflows for querying and event-driven triggers.

Data

MongoDB

Tasks that query and manipulate MongoDB collections.

Data

Argo CD

GitOps-focused tasks that interact with Argo CD using the Argo CD CLI. Tasks are executed inside a container and rely on the official Argo CD CLI to perform application synchronization and status inspection.

Infrastructure

Subscribe

Subscribe and buffer MQTT messages

More Plugins in this Category

Apache Cassandra

MongoDB

Argo CD

1.1.3

Subscribe Subscribe and buffer MQTT messages

More Plugins in this Category

Apache Cassandra

MongoDB

Argo CD

1.1.3

Subscribe

Subscribe and buffer MQTT messages