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.
