Skip to main content

Distributed MQTT broker in Rust

YedMQ logoYedMQ

Distributed MQTT broker in Rust with tenant isolation, cluster support, and flexible extensions.

Build tenant-aware IoT messaging services around the capabilities teams care about: MQTT v3.1.1, cluster support, REST management APIs, and flexible extension points.

MQTT v3.1.1TCP / TLS / WS / WSSTenant scopedPlugin hooks
Project status: The source repository is still private. YedMQ remains under active development and is not yet recommended for production use.
yedmq@node-01:~

$ yedmq inspect current-surface

[INFO] reading broker capabilities from docs and config surface

protocolMQTT v3.1.1
qos0 / 1 / 2
listenerstcp, tls, ws, wss
managementREST API
tenancypublic + isolated tenants
extensionsauth, acl, message flow

$ _

Protocol

MQTT core with retained messages, last will, persistent sessions, and message limits.

Cluster

Multi-node deployment workflows for scale-out and availability planning.

Operations

Management endpoints for plugins, clients, topics, retained data, and system info.

Capability map

Capabilities aligned with the current codebase

The website now reflects what YedMQ currently implements instead of promising future functionality.

Implemented surface

MQTT broker core

MQTT v3.1.1 support with QoS 0, 1, and 2, retained messages, last will, persistent sessions, and configurable message limits.

QoS 0/1/2RetainWill
Implemented surface

Cluster support

Deploy YedMQ across multiple nodes for scale-out scenarios and more resilient operations.

BootstrapJoin
Implemented surface

Tenant isolation

Clients, topics, retained messages, and management operations are scoped by tenant, with public as the default tenant.

Scoped datapublic
Implemented surface

Flexible plugin support

Use plugins to connect authentication, authorization, and custom message handling to your own business flows.

AuthACLMessage
Implemented surface

REST operations

Management endpoints cover plugins, clients, topics, retained messages, system info, and cluster workflows.

OpenAPIOps