Subscribe

Subscribe
Certified
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_ssl
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: "{{ secret('MQTT_CA_CERT') }}"
    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

pluginDefaultsRef string

qos integerstring

Default1

serdeType string

DefaultJSON

Possible Values

STRINGJSONBYTES

username string

Outputs

messagesCount integer

uri string

Formaturi

Metrics

duration timer

records counter

NetBox

Enterprise

Enterprise NetBox tasks to create, update, and query devices, IP addresses, and sites over the NetBox API.

Infrastructure

DocumentDB

Tasks that manage DocumentDB collections with MongoDB-compatible insert, query, update, and delete operations.

Data

SubscribeCertifiedSubscribe and buffer MQTT messages

More Plugins in this Category

NetBox

DocumentDB

Subscribe
Certified
Subscribe and buffer MQTT messages