Subscribe

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

clientId *string

server *string

topic *object

authMethod string

connectionTimeout string

Formatduration

crt string

httpsHostnameVerificationEnabled booleanstring

maxDuration string

Formatduration

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 Pulsar

Tasks that publish, consume, and trigger workflows with Apache Pulsar.

Messaging

AMQP

Tasks that connect to RabbitMQ brokers to declare exchanges and queues, bind routing keys, publish messages, and consume them via tasks or triggers (batch or real time).

Messaging

AWS

AWS plugin for Kestra

AlertingCloudMessagingStorageDatabaseScriptToolTransformation

More Plugins in this Category

Apache Pulsar

AMQP

AWS