Logo
Deploy Now

Categories

Self-Hosted Messaging IoT Real-Time MQTT Broker Erlang

Stars

16,647

Forks

2,545

Watchers

379

Developer links

Last Updated: 08-21-2026 07:34 AM (UTC)

EMQX

With over 16,500 GitHub stars and a track record powering connected vehicle fleets, smart city sensor networks, and industrial IoT deployments, EMQX is the MQTT messaging platform engineered to handle 100 million concurrent device connections in a single cluster while processing millions of messages per second with sub-millisecond latency. The protocol stack supports MQTT 5.0, 3.1.1, and 3.1 with full QoS 0/1/2 support, shared subscriptions, retained messages, and will messages, plus MQTT over QUIC for faster connection setup, reduced head-of-line blocking, and seamless connection migration on mobile networks. The gateway framework extends connectivity to MQTT-SN, CoAP, LwM2M, STOMP, and ExProto for bridging legacy industrial protocols. The SQL-based rule engine processes and transforms messages in real time with over 50 pre-built integrations including Kafka, PostgreSQL, MySQL, MongoDB, InfluxDB, TimescaleDB, ClickHouse, Redis, AWS Kinesis, GCP Pub/Sub, and Azure Event Hubs. The visual Flow Designer creates data processing pipelines without code. Built on Erlang/OTP with a masterless distributed architecture using Mria for state replication, the cluster separates Core nodes for data consistency and Replicant nodes for client-handling workloads. Authentication supports username/password, JWT, PSK, X.509 certificates, and LDAP with configurable ACL rules. The built-in dashboard provides real-time monitoring of connections, subscriptions, topics, message rates, and cluster health. Deployment runs via Docker, Kubernetes with the EMQX Operator, or native packages. Running on a dedicated VPS on RepoCloud with guaranteed CPU, RAM, and SSD, full root SSH access, and a browser serial console. BSL 1.1 licensed.

EMQX
EMQX
EMQX
EMQX
EMQX

Benefits

  • 100M+ Concurrent MQTT Connections
  • A single EMQX cluster handles over 100 million concurrent device connections while processing millions of messages per second with sub-millisecond latency on Erlang/OTP infrastructure.
  • 50+ Backend Data Integrations
  • The SQL-based rule engine processes messages in real time with pre-built integrations for Kafka, PostgreSQL, InfluxDB, TimescaleDB, ClickHouse, Redis, AWS Kinesis, and Azure Event Hubs.
  • MQTT over QUIC Transport
  • QUIC-based transport provides faster connection setup, reduced head-of-line blocking, and seamless connection migration for mobile and vehicular IoT networks with unreliable connectivity.
  • Masterless Distributed Architecture
  • Erlang/OTP-based clustering with Mria state replication separates Core and Replicant node roles for horizontal scaling and high availability without single points of failure.

Features

  • Visual Flow Designer
  • Drag-and-drop pipeline builder creates data processing workflows connecting MQTT messages to backend systems without writing code for rapid integration development.
  • Multi-Protocol Gateway
  • The gateway framework bridges MQTT-SN, CoAP, LwM2M, STOMP, and ExProto devices to the MQTT ecosystem for legacy industrial protocol connectivity.
  • SQL Rule Engine
  • SQL expressions filter, transform, and route messages in real time with built-in functions for JSON parsing, encoding, and conditional branching logic.
  • Flexible Authentication
  • Supports username/password, JWT tokens, PSK, X.509 client certificates, and LDAP with configurable ACL rules for fine-grained topic-level access control.
  • Built-In Monitoring Dashboard
  • Real-time web dashboard displays connections, subscriptions, topics, message rates, rule engine metrics, and cluster node health with alerting capabilities.