Message Brokers & Streaming

Open-source communication protocol that blends pub/sub messaging with geo-distributed storage and query capabilities. Designed for edge-to-cloud scenarios with minimal wire overhead.

Distributed MQTT message broker built on Erlang/OTP for high-performance industrial IoT applications. Features clustering, automatic network partition recovery, Lua scripting, and webhook support.

EMQX is a unified MQTT platform that connects, processes, and streams data from millions of IoT devices to cloud, AI, and analytics systems. It supports 100M+ concurrent connections per cluster with sub-millisecond latency.

Java-based MQTT broker that fully supports MQTT 3.x and MQTT 5. The Community Edition is open-source under Apache 2.0, while Enterprise adds clustering, monitoring, and professional support.

Strimzi is a CNCF Incubating project that provides Kubernetes operators for deploying and managing Apache Kafka clusters. It simplifies Kafka operations through Custom Resources, automated TLS encryption, and integrations with Kafka Connect, MirrorMaker 2.0, and Cruise Control.

RabbitMQ is an enterprise-grade open-source message broker built on Erlang/OTP. It supports AMQP, MQTT 5.0, STOMP, and streaming via a plugin architecture.

Confluent Platform is the enterprise distribution of Apache Kafka, adding ksqlDB for SQL stream processing, Schema Registry for data governance, 120+ Kafka Connect connectors, and enterprise security features including RBAC and audit logging.

NATS is a high-performance messaging system for distributed architectures, supporting pub/sub, request-reply, and queue groups. JetStream adds optional persistence with at-least-once delivery guarantees.

Redis is an open-source, in-memory data structure store used as a database, cache, message broker, and streaming engine. Redis Streams provides a log data structure for event sourcing and real-time data pipelines.

Apache Pulsar is an open-source, cloud-native distributed messaging and streaming platform that combines pub/sub messaging and event streaming in a unified architecture. Its tiered storage and native multi-tenancy enable indefinite message retention and strong isolation for large-scale deployments.

Apache Kafka is an open-source distributed event streaming platform for high-performance data pipelines, streaming analytics, and mission-critical applications. Handles trillions of events per day with durable, fault-tolerant storage.

Lightweight message broker implementing MQTT 5.0, 3.1.1, and 3.1. Written in C with a ~200KB memory footprint, Mosquitto runs on everything from Raspberry Pis to full servers and is the default MQTT broker in most IIoT starter stacks.