Publish and consume from MQTT brokers
Field | Description | Required | Example |
---|---|---|---|
url | The URL of the MQTT broker | Yes | tcp://localhost:1883 |
username | Username for the MQTT broker | For password auth | bob |
password | Password for the MQTT broker | for password auth | hunter2 |
tls.ca | Path to the CA file | For TLS auth | /mount/certs/ca.pem |
tls.cert | Path to the client cert file auth | For TLS auth | /mount/certs/client.pem |
tls.key | Path to the client key file | For TLS auth | /mount/certs/client.key |
topic | The MQTT topic to read or write from | Yes | events |
qos | One of ‘AtMostOnce’, ‘AtleastOnce’, or ‘ExactlyOnce’ | No | AtMostOnce |
type | Either ‘source’ or ‘sink’ | Yes | source |
sink.retain | Whether to retain messages published to this topic | No | false |
connection_profile
option in the WITH
clause.
See the connection profile docs for more details.
topic TEXT
- the MQTT topic the message was consumed from