MQTT | Kestra

Kestra 1.3 is here: Production grade orchestration with LTS support

Item 1 of 1

MQTT

Tasks that publish, subscribe, and trigger workflows with MQTT.
Set the broker URI, client ID, topics, QoS, and credentials to send or receive MQTT messages, with triggers that start flows when subscribed messages arrive.

tasks

Publish

io.kestra.plugin.mqtt.Publish

triggers

RealtimeTrigger

io.kestra.plugin.mqtt.RealtimeTrigger

Trigger

io.kestra.plugin.mqtt.Trigger

Apache Cassandra

Tasks that integrate Apache Cassandra into Kestra workflows for querying and event-driven triggers.

Data

Git

Tasks that clone, fetch, and interact with Git repositories.

InfrastructureBusiness

MongoDB

Tasks that query and manipulate MongoDB collections.

Data

OVERVIEW

Versions

1.1.3

Latest

February 26, 2026 Release Notes Min. Compatible Kestra Version: 1.2.3

Previous Versions

1.1.2February 16, 2026 Min. Compatible Kestra Version: 1.2.3

1.1.1January 5, 2026 Min. Compatible Kestra Version: 1.0.0

1.1.0November 3, 2025 Min. Compatible Kestra Version: 1.0.0

1.0.0September 8, 2025 Min. Compatible Kestra Version: 1.0.0

Created by

Kestra Core Team

Managed by

Kestra Core Team

Plugin Type

DataInfrastructure

Links & Resources

GitHub

Table of Contents

MQTT Tasks that publish, subscribe, and trigger workflows with MQTT.Set the broker URI, client ID, topics, QoS, and credentials to send or receive MQTT messages, with triggers that start flows when subscribed messages arrive.