Pushes messages to an MQTT broker.
output:mqtt:urls:- tcp://localhost:1883qos: 1topic: benthos_topicclient_id: benthos_outputmax_in_flight: 1
topic field can be dynamically set using function interpolations
described here. When sending batched
messages these interpolations are performed per message part.
This output benefits from sending multiple messages in flight in parallel for
improved performance. You can tune the max number of in flight messages with the
array A list of URLs to connect to. If an item of the list contains commas it will be expanded into multiple URLs.
# Examplesurls:- tcp://localhost:1883
number The QoS value to set for each message.
string The topic to publish messages to.
string An identifier for the client.
string A username to connect with.
string A password to connect with.
number The maximum number of messages to have in flight at a given time. Increase this to improve throughput.