Plugin Mqtt

Subscribe ​Subscribe

yaml
type: "io.kestra.plugin.mqtt.subscribe"
yaml
id: mqtt_subscribe
namespace: company.team

tasks:
  - id: subscribe
    type: io.kestra.plugin.mqtt.Subscribe
    server: tcp://localhost:1883
    clientId: kestraProducer
    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
    topic:
      - kestra/sensors/cpu
      - kestra/sensors/mem
    crt: /home/path/to/ca.crt
    serdeType: JSON
    maxRecords: 10
Properties
Format duration
Format duration
Default V5
Possible Values
V3V5
Default 1
Default JSON
Possible Values
STRINGJSONBYTES
Format uri