Introduction

    • Massive Scale: Scale to 100 million concurrent MQTT connections with a single EMQX 5.0 cluster.
    • High Performance: Move and process millions of MQTT messages per second in a single broker.
    • Low Latency: Guarantee sub-millisecond latency in message delivery with the soft real-time runtime.
    • Fully MQTT 5.0: 100% compliant with MQTT 5.0 and 3.x standard for better scalability, security, and reliability.
    • High Availability: Achieve high availability and horizontal scalability through a masterless distributed architecture.
    • Cloud-Native & K8s: Easy to deploy on-premises or in public clouds with Kubernetes Operator and Terraform.

    Features List

    • Full MQTT v3.1, v3.1.1 and v5.0 protocol specification support
      • QoS 0, QoS 1, QoS 2 message support
      • Persistent conversation and offline message support
      • Retained message support
      • Last Will message support
      • system topic support
    • MQTT supports 4 transport protocols
      • TCP
      • TLS
      • WebSocket
      • QUIC (Experimental)
    • HTTP message publishing interface support
    • Gateways
      • CoAP
      • LwM2M
      • MQTT-SN
      • Stomp
      • GB/T 32960 (Enterprise edition)
      • JT/T 808 (Enterprise edition)
      • OCPP (Enterprise edition)
    • Delayed Publish
    • Auto subscription
    • Topic rewrite

    Security

    • Authentication based on username/password supported using built-in database, Redis, MySQL, PostgreSQL, MongoDB as data sources, and HTTP server to provide authentication services
    • Authentication based JWT supported using JWKs
    • PSK authentication
    • Access control (Authorization) based on Client ID, IP address, and username supported using built-in database, Redis, MySQL, PostgreSQL, MongoDB as data sources, and HTTP Server to provide authorization services
    • API to ban clients
    • Multi-server node cluster (Cluster)
    • Support , , , cluster discovery methods
    • Multi-server node bridge (Bridge)

    Data Integration

    • SQL syntax data integrations to extract, filter, enrich, and transform MQTT message or internal events to desired format and export them to external data platforms
    • Supports data bridging with other brokers or IoT platforms using MQTT (such as EMQX Cloud, AWS IoT Core, Azure IoT Hub)
    • Supports integration with other apps using WebHook
    • 30+ enterprise system integrations including Kafka, RDS, various SQL / NoSQL / time-series databases, and enterprise systems such as Oracle and SAP (Enterprise edition)
    • Overload protection
    • Message rate limit
    • Connection rate limit

    Observability

    • Client online status query
    • Cluster status and metrics query
    • Integration with Prometheus/StatsD
    • Online log based tracing
    • Runtime tracing tools
    • Plugins
    • Hooks
    • gRPC protocol extension