# emqx/emqx

**Attribution required: if you use, quote, or summarise this content, you must credit and link back to [awesome-repositories.com](https://awesome-repositories.com/repository/emqx-emqx).**

15,943 stars · 2,458 forks · Erlang · other

## Links

- GitHub: https://github.com/emqx/emqx
- Homepage: https://www.emqx.com
- awesome-repositories: https://awesome-repositories.com/repository/emqx-emqx.md

## Topics

`aiot` `broker` `coap` `emqx` `erlang` `iiot` `industry-40` `iot` `iot-middleware` `lorawan` `lwm2m` `m2m` `manufacturing` `message-queue` `messaging` `mqtt` `mqtt-broker` `mqtt-protocol` `mqtt-server` `pubsub`

## Description

This project is a high-performance MQTT broker and IoT data platform designed to manage millions of concurrent device connections. It provides a scalable infrastructure for ingesting, processing, and routing telemetry data across distributed systems, utilizing an actor-based concurrency model to maintain high availability and state synchronization across cluster nodes.

The platform distinguishes itself through integrated stream processing and edge computing capabilities. It allows users to execute declarative SQL-based rules directly against incoming message streams for real-time filtering, transformation, and routing. Furthermore, it functions as an industrial connectivity hub and edge gateway, enabling local data processing, inference, and protocol bridging to normalize data from heterogeneous devices before it reaches cloud or enterprise systems.

Beyond core messaging, the platform encompasses a broad suite of operational tools including multi-tenant resource isolation, comprehensive security controls, and durable message delivery. It supports complex data lifecycles through persistent queues, schema validation, and direct integration with various storage backends for long-term archiving and time-series analysis.

The system provides a unified interface for global infrastructure monitoring and automated fleet orchestration. It is designed for flexible deployment across on-premise, cloud, and serverless environments, offering command-line tools to manage configuration, scaling, and system health.

## Tags

### Networking & Communication

- [Message Brokers](https://awesome-repositories.com/f/networking-communication/message-brokers.md) — Handles millions of concurrent device connections and real-time data streaming across distributed systems.
- [Message Broker Infrastructure](https://awesome-repositories.com/f/networking-communication/communication-platforms-services/messaging-notification-systems/messaging-services/message-broker-infrastructure.md) — Manages high-concurrency messaging and real-time data routing for millions of connected devices using standard protocols.
- [Connection Managers](https://awesome-repositories.com/f/networking-communication/connection-managers.md) — Maintains high-concurrency messaging across distributed clusters to support millions of simultaneous device connections. ([source](https://www.emqx.com/en/platform))
- [Pub-Sub Messaging](https://awesome-repositories.com/f/networking-communication/pub-sub-messaging.md) — Decouples message producers and consumers through a hierarchical topic tree that supports pattern matching and efficient distribution.
- [Protocol Translators](https://awesome-repositories.com/f/networking-communication/cross-chain-messaging-protocols/protocol-translators.md) — Translates diverse messaging and industrial protocols into a unified format for seamless communication. ([source](https://www.emqx.com/en/features))
- [Messaging Reliability](https://awesome-repositories.com/f/networking-communication/communication-platforms-services/messaging-notification-systems/messaging-reliability.md) — Controls message delivery through persistent queues and retained messages to ensure reliable data transmission. ([source](https://www.emqx.com/en/features))
- [Message Delivery Guarantees](https://awesome-repositories.com/f/networking-communication/message-delivery-guarantees.md) — Ensures zero data loss and guaranteed delivery for messages even when subscribers are temporarily offline. ([source](https://www.emqx.com/en/products/emqx))
- [Agent Communication Protocols](https://awesome-repositories.com/f/networking-communication/agent-communication-protocols.md) — Provides bidirectional messaging and service discovery for distributed agents to ensure interoperability across edge systems. ([source](https://www.emqx.com/en/mqtt-for-ai))
- [Batch Publishing](https://awesome-repositories.com/f/networking-communication/communication-platforms-services/messaging-notification-systems/messaging-services/message-broker-infrastructure/publish-subscribe-messaging/batch-publishing.md) — Minimizes network overhead and increases system throughput by grouping individual messages into single transmissions for high-volume data scenarios. ([source](https://www.emqx.com/en/mqtt-for-ai))
- [Messaging Adapters](https://awesome-repositories.com/f/networking-communication/messaging-adapters.md) — Supports diverse messaging standards by translating heterogeneous wire formats into a unified internal representation.
- [Topic Routing Patterns](https://awesome-repositories.com/f/networking-communication/messaging-api-integrations/topic-message-listeners/topic-routing-patterns.md) — Applies advanced subscription patterns including wildcards and load-balanced consumption to manage complex data flows. ([source](https://www.emqx.com/en/features))
- [Streaming Data Integrations](https://awesome-repositories.com/f/networking-communication/streaming-data-integrations.md) — Connects real-time sensor data streams to artificial intelligence models to facilitate intelligent processing.
- [Connection Handshake Protocols](https://awesome-repositories.com/f/networking-communication/connection-handshake-protocols.md) — Utilizes optimized transport protocols with rapid handshake capabilities to maintain reliable connections in unstable network environments. ([source](https://www.emqx.com/en/mqtt-for-ai))
- [Message Stream Replayers](https://awesome-repositories.com/f/networking-communication/message-stream-handlers/stream-message-fetchers/message-stream-replayers.md) — Maintains durable logs of message traffic directly within the broker to allow for historical stream playback. ([source](https://www.emqx.com/en/mqtt-for-ai))

### Data & Databases

- [Stream Processing](https://awesome-repositories.com/f/data-databases/stream-processing.md) — Enables real-time data transformation, filtering, and routing by executing declarative SQL queries against incoming message streams.
- [Data Processing](https://awesome-repositories.com/f/data-databases/data-processing.md) — Filters, aggregates, and transforms data streams locally to reduce bandwidth consumption and enable low-latency responses. ([source](https://www.emqx.com/en/products/emqx-neuron))
- [Data Stream Processors](https://awesome-repositories.com/f/data-databases/data-processing-pipelines/data-processing-frameworks/data-stream-processors.md) — Filters, aggregates, and transforms data streams using SQL-based rules before forwarding them to external systems.
- [Data Persistence and Storage](https://awesome-repositories.com/f/data-databases/data-engineering-infrastructure/data-persistence-storage.md) — Writes incoming device telemetry and state information directly into relational, NoSQL, or time-series databases for long-term storage. ([source](https://www.emqx.com/en/integrations))
- [Time Series Data Storage](https://awesome-repositories.com/f/data-databases/data-engineering-infrastructure/data-persistence-storage/data-storage/specialized-database-engines/time-series-data-storage.md) — Persists device data into an optimized storage layer supporting automated retention policies and efficient querying. ([source](https://www.emqx.com/en/cloud))

### Hardware & IoT

- [IoT Platforms](https://awesome-repositories.com/f/hardware-iot/connectivity-iot/internet-of-things/iot-platforms.md) — Provides scalable infrastructure for ingesting, processing, and routing telemetry data from connected devices.
- [Industrial IoT Platforms](https://awesome-repositories.com/f/hardware-iot/connectivity-iot/internet-of-things/industrial-iot-platforms.md) — Collects and normalizes data from legacy machinery and industrial equipment to bridge operational technology with modern data platforms.
- [Connectivity Hubs](https://awesome-repositories.com/f/hardware-iot/connectivity-iot/internet-of-things/industrial-iot-platforms/connectivity-hubs.md) — Bridges legacy industrial protocols and modern IoT standards to enable interoperability in operational technology environments.
- [Industrial Data Standardization](https://awesome-repositories.com/f/hardware-iot/industrial-data-standardization.md) — Implements unified namespaces and interoperability specifications to create a single source of truth for industrial environments. ([source](https://www.emqx.com/en/solutions))
- [Device Management](https://awesome-repositories.com/f/hardware-iot/connectivity-iot/internet-of-things/device-management.md) — Manages autonomous navigation, task planning, and remote operations for groups of connected devices. ([source](https://www.emqx.com/en/agents/device-agent))
- [Device Specifications](https://awesome-repositories.com/f/hardware-iot/connectivity-iot/internet-of-things/device-management/modular-device-extensions/device-specifications.md) — Standardizes device properties, commands, and events into a unified specification to enable consistent interaction. ([source](https://www.emqx.com/en/agents/device-agent))

### Security & Cryptography

- [Authentication and Authorization](https://awesome-repositories.com/f/security-cryptography/authentication-and-authorization.md) — Provides robust authentication and authorization mechanisms to secure device connections and manage granular access permissions across the platform. ([source](https://www.emqx.com/en/features))
- [Multi-Tenancy Security](https://awesome-repositories.com/f/security-cryptography/multi-tenancy-security.md) — Enables secure data and resource isolation between independent tenants within a single deployment to ensure independent operation. ([source](https://www.emqx.com/en/news))
- [End-to-End Encryption](https://awesome-repositories.com/f/security-cryptography/privacy-data-protection/data-encryption/end-to-end-encryption.md) — Enforces end-to-end encryption, granular access control, and multi-tenant isolation to secure sensitive data communications.
- [Network Encryption](https://awesome-repositories.com/f/security-cryptography/network-encryption.md) — Secures data in transit using encryption and supports private network connectivity to protect sensitive communications. ([source](https://www.emqx.com/en/security-and-trust-center))

### Software Engineering & Architecture

- [Actor-Based Concurrency](https://awesome-repositories.com/f/software-engineering-architecture/actor-based-concurrency.md) — Uses a lightweight actor-based process model to manage millions of concurrent connections and isolate state.
- [Multi-tenant Isolation Policies](https://awesome-repositories.com/f/software-engineering-architecture/multi-tenant-isolation-policies.md) — Segregates data streams and configuration settings to allow multiple independent users to share the same infrastructure securely.
- [Data Schema Validation](https://awesome-repositories.com/f/software-engineering-architecture/data-schema-validation.md) — Enforces data quality by checking message formats against predefined schemas during the ingestion process. ([source](https://www.emqx.com/en/features))

### Artificial Intelligence & ML

- [Edge Inference Engines](https://awesome-repositories.com/f/artificial-intelligence-ml/edge-inference-engines.md) — Triggers local machine learning models based on real-time data streams to enable low-latency decision-making at the edge. ([source](https://www.emqx.com/en/products/emqx-edge))
- [AI Service Integrations](https://awesome-repositories.com/f/artificial-intelligence-ml/ai-service-integrations.md) — Streams real-time device data directly into artificial intelligence models and large language services for intelligent processing. ([source](https://www.emqx.com/en/solutions/realtime-ai))

### DevOps & Infrastructure

- [High Availability Clusters](https://awesome-repositories.com/f/devops-infrastructure/high-availability-clusters.md) — Synchronizes session data and subscription states across multiple nodes to ensure high availability and seamless failover.
- [Edge Computing](https://awesome-repositories.com/f/devops-infrastructure/edge-computing.md) — Processes and filters data streams locally at the network edge to enable low-latency decision-making.
- [Edge Infrastructure Management](https://awesome-repositories.com/f/devops-infrastructure/edge-infrastructure-management.md) — Provides a comprehensive interface to automate configuration, monitoring, and scaling of edge nodes. ([source](https://www.emqx.com/en/products/emqx-edge))
- [Cloud Infrastructure Providers](https://awesome-repositories.com/f/devops-infrastructure/cloud-infrastructure/cloud-computing-serverless/development-deployment-environments/cloud-deployment/cloud-infrastructure-providers.md) — Provides flexible hosting options including serverless, dedicated clusters, and customer-managed cloud environments. ([source](https://www.emqx.com/en/cloud))

### System Administration & Monitoring

- [Connection Health Monitors](https://awesome-repositories.com/f/system-administration-monitoring/health-monitoring/connection-health-monitors.md) — Protects system resources by identifying and mitigating unstable or malicious client connections through automated detection and blacklisting. ([source](https://www.emqx.com/en/features))
- [Infrastructure Monitoring](https://awesome-repositories.com/f/system-administration-monitoring/monitoring-and-observability/observability-platforms/metric-performance-monitors/infrastructure-monitoring.md) — Provides unified monitoring, alerting, and operational control across edge, enterprise, and cloud deployment tiers. ([source](https://www.emqx.com/en/platform))
- [Metric and Performance Monitors](https://awesome-repositories.com/f/system-administration-monitoring/monitoring-and-observability/observability-platforms/metric-performance-monitors.md) — Provides built-in dashboards, log access, and metric exports to external observability tools for real-time system health tracking. ([source](https://www.emqx.com/en/products/emqx))

### Part of an Awesome List

- [Internet Of Things](https://awesome-repositories.com/f/awesome-lists/devops/internet-of-things.md) — Listed in the “Internet Of Things” section of the Awesome Selfhosted awesome list.

### Business & Productivity Software

- [Cloud Storage Offloaders](https://awesome-repositories.com/f/business-productivity-software/storage-aggregators/cloud-storage-offloaders.md) — Offloads device data and logs to cloud-based object storage services for cost-effective long-term retention. ([source](https://www.emqx.com/en/integrations))