function: message-queue
582 products, primary matches first, then adoption-weighted; health v2 shown.
| Product | Health v2 | Stars | Maturity |
|---|---|---|---|
| Redis Redis is an open-source, in-memory data structure server written in C that doubles as a cache, NoSQL data store, message broker, and docume… | 95 | 76114 | stable |
| ntfy ntfy is a simple HTTP-based pub-sub notification service that lets you send push notifications to your phone or desktop via PUT/POST reques… | 98 | 33775 | stable |
| apache/kafka Apache Kafka is an open-source distributed event streaming platform for building high-performance data pipelines, streaming analytics, and … | 77 | 33632 | stable |
| dragonflydb/dragonfly Dragonfly is a modern in-memory data store that is fully API-compatible with Redis and Memcached, built on a multi-threaded, shared-nothing… | 98 | 31043 | active |
| block/buzz Buzz is a self-hostable team workspace where humans and AI agents collaborate in shared rooms, built on a Nostr relay where every message, … | 77 | 30914 | active |
| alibaba/canal Canal is an Alibaba open-source component that parses MySQL binlog to provide incremental data subscription and consumption. It masquerades… | 66 | 29725 | stable |
| Celery Celery is a Python distributed task queue for processing large volumes of messages asynchronously, with support for real-time task executio… | 91 | 28826 | stable |
| valkey-io/valkey Valkey is an open-source (BSD-3-Clause), high-performance in-memory key-value data structure server forked from Redis before its license ch… | 90 | 26991 | stable |
| NSQ NSQ is a realtime distributed messaging platform written in Go, designed to operate at scale handling billions of messages per day. It prov… | 66 | 25775 | stable |
| redisson/redisson Redisson is a Java client and real-time data platform for Redis and Valkey, built on Netty, offering sync, async, reactive, and RxJava3 API… | 98 | 24378 | stable |
| apache/rocketmq Apache RocketMQ is a distributed cloud-native messaging and streaming platform built for low-latency, high-throughput, financially reliable… | 90 | 22570 | stable |
| NATS NATS Server is a high-performance, lightweight open-source messaging system written in Go that provides pub/sub, request/reply, and durable… | 98 | 20603 | stable |
| LMAX-Exchange/disruptor LMAX Disruptor is a high-performance, lock-free inter-thread messaging library for the JVM built around a ring buffer with 'mechanical symp… | 29 | 18451 | stable |
| emqx/emqx EMQX is a highly scalable MQTT broker and messaging platform written in Erlang, supporting MQTT 5.0/3.1.1/3.1 plus MQTT-SN, CoAP, LwM2M, an… | 99 | 16659 | stable |
| Zigbee2MQTT Zigbee2MQTT is a Node.js application that bridges Zigbee devices to MQTT, letting you control Zigbee sensors, bulbs, and switches without t… | 98 | 15574 | stable |
| apache/pulsar Apache Pulsar is a cloud-native, distributed pub-sub messaging and streaming platform originally developed at Yahoo and now a top-level Apa… | 98 | 15315 | stable |
| RabbitMQ RabbitMQ is an open source, multi-protocol messaging and streaming broker supporting AMQP 0-9-1, AMQP 1.0, MQTT, STOMP, and its Streams pro… | 99 | 13807 | stable |
| hibiken/asynq Asynq is a Go library for a distributed task queue backed by Redis, letting clients enqueue tasks that worker servers process concurrently.… | 73 | 13659 | stable |
| sidekiq/sidekiq Sidekiq is a simple, efficient background job processing framework for Ruby applications, using threads to handle many jobs concurrently in… | 76 | 13553 | stable |
| IBM/sarama Sarama is an MIT-licensed Go client library for Apache Kafka, providing pure-Go implementations of Kafka producers, consumers, and administ… | 99 | 12510 | stable |
| redpanda-data/redpanda Redpanda is a Kafka API-compatible streaming data platform written in C++ on the Seastar framework, with no ZooKeeper or JVM dependency. It… | 94 | 12486 | stable |
| LuckyPennySoftware/MediatR MediatR is a simple, dependency-free mediator implementation for .NET that supports in-process messaging with request/response, commands, q… | 84 | 11858 | stable |
| eclipse-mosquitto/mosquitto Eclipse Mosquitto is an open source MQTT message broker implementing MQTT versions 5.0, 3.1.1, and 3.1, written in C and suitable for devic… | 77 | 11158 | stable |
| ZeroMQ ZeroMQ (libzmq) is a high-performance, brokerless asynchronous messaging library implementing the ZMTP protocol, providing socket-like abst… | 65 | 10972 | stable |
| dicedb/dicedb DiceDB is an open-source, low-latency key/value data store forked from Valkey (itself a fork of Redis), written in C. It extends Valkey wit… | 68 | 10772 | active |
| RQ RQ (Redis Queue) is a simple Python library for queueing jobs and processing them in the background with workers, backed by Redis or Valkey… | 95 | 10670 | stable |
| Centrifugo Centrifugo is an open-source, language-agnostic real-time messaging (PUB/SUB) server written in Go that delivers messages to online users o… | 99 | 10668 | stable |
| AutoMQ/automq AutoMQ is a cloud-native, 100% Apache Kafka-compatible streaming platform that replaces broker-local disks with S3-compatible object storag… | 95 | 10574 | active |
| ThreeDotsLabs/watermill Watermill is a Go library for building event-driven and message-driven applications over a unified Pub/Sub API. It supports Kafka, RabbitMQ… | 95 | 9864 | active |
| gomodule/redigo Redigo is a Go client library for the Redis and Valkey databases, providing a Print-like API supporting all Redis commands. It includes con… | 49 | 9857 | stable |
| agenda/agenda Agenda is a lightweight job scheduling library for Node.js that persists jobs in MongoDB, PostgreSQL, or Redis and supports cron-style or h… | 95 | 9699 | active |
| apache/seatunnel Apache SeaTunnel is a distributed, high-performance data integration platform for synchronizing massive amounts of data across hundreds of … | 82 | 9587 | stable |
| crossoverJie/cim CIM (Cross IM) is a distributed instant messaging system for developers built with Java, Netty, and Spring Boot. It provides server and cli… | 57 | 9492 | active |
| Resque Resque is a Redis-backed Ruby library for creating background jobs, placing them on multiple queues, and processing them later with forked … | 74 | 9480 | stable |
| taskforcesh/bullmq BullMQ is a fast, robust message queue and background job processing library built on Redis (or PostgreSQL), available natively for Node.js… | 95 | 9333 | stable |
| firebase/flutterfire FlutterFire is a collection of official Firebase plugins for Flutter apps, maintained by Google. It enables Flutter applications to integra… | 67 | 9251 | stable |
| aeron-io/aeron Aeron is an efficient, reliable message transport supporting UDP unicast, UDP multicast, and IPC, with Java, C, and C++ clients. It include… | 99 | 8818 | stable |
| redpanda-data/connect Redpanda Connect (formerly Benthos) is a declarative stream processor that moves data between hundreds of sources and sinks with transforma… | 95 | 8736 | active |
| segmentio/kafka-go kafka-go is a pure-Go Apache Kafka client library offering both low-level connection APIs and high-level Reader/Writer abstractions for pro… | 75 | 8613 | active |
| timercrack/trader An automated futures trading application built around the CTP native gateway, with a pybind11 C++ bridge to the Thost API, a Python-side ga… | 63 | 8425 | active |
| RichardKnop/machinery Machinery is a Go library for asynchronous task and job queues built on distributed message passing. It supports multiple brokers (RabbitMQ… | 59 | 7972 | stable |
| MassTransit/MassTransit MassTransit is a free, open-source distributed application framework for .NET that enables message-based, loosely-coupled asynchronous comm… | 70 | 7798 | active |
| hatchet-dev/hatchet Hatchet is an open-source (MIT) orchestration engine for background tasks, AI agents, and durable workflows, available as a cloud service o… | 89 | 7792 | active |
| deepstreamIO/deepstream.io deepstream is an open-source realtime server that synchronizes schema-less records, provides publish-subscribe events, and routes RPCs betw… | 96 | 7187 | active |
| dotnetcore/CAP CAP is a .NET library providing a lightweight event bus and a distributed transaction solution based on the Outbox pattern (local message t… | 92 | 7107 | active |
| processone/ejabberd ejabberd is an open-source, massively scalable real-time messaging platform written in Erlang/OTP that combines an XMPP server, MQTT broker… | 93 | 6721 | stable |
| Hazelcast Hazelcast is a unified real-time data platform combining distributed stream processing with a fast, in-memory data store. It lets applicati… | 82 | 6604 | stable |
| apache/camel Apache Camel is an open-source integration framework offering 350+ connectors for databases, APIs, message brokers, and cloud services, wit… | 77 | 6300 | stable |
| contribsys/faktory Faktory is a language-agnostic background job server that stores jobs as JSON in queues for workers in any programming language to fetch an… | 87 | 6141 | active |
| JackJiang2011/MobileIMSDK MobileIMSDK is an original, lightweight cross-platform instant messaging (IM) communication-layer framework refined over 10 years. It uniqu… | 69 | 6085 | stable |
| ZhongFuCheng3y/austin Austin is a unified message push platform written in Java (Spring Boot) that sends notifications across channels such as email, SMS, WeChat… | 71 | 6072 | active |
| coleifer/huey Huey is a lightweight Python task queue supporting Redis, Postgres, SQLite, file-system, or in-memory storage. It offers scheduled, periodi… | 98 | 6012 | active |
| dpkp/kafka-python kafka-python is a pure-Python client library for Apache Kafka with no external dependencies, providing high-level consumer, producer, and a… | 99 | 5898 | active |
| kurrent-io/KurrentDB KurrentDB (formerly EventStoreDB) is an event-native database designed for event-driven architectures, storing data as immutable event stre… | 99 | 5848 | active |
| dockersamples/example-voting-app A sample distributed voting application composed of multiple containers (Python front-end, .NET worker, Node.js results app, Redis, Postgre… | 32 | 5791 | stable |
| edenhill/kcat kcat (formerly kafkacat) is a lightweight, non-JVM command-line tool for producing to and consuming from Apache Kafka topics, akin to netca… | 23 | 5778 | stable |
| inngest/inngest Inngest is an event-driven durable execution platform for running stateful step functions and AI workflows on serverless, servers, or the e… | 95 | 5766 | active |
| rmax/scrapy-redis Redis-based components for Scrapy that enable distributed crawling and scraping by sharing a Redis queue across multiple spider instances. … | 60 | 5642 | active |
| soketi/soketi Soketi is an open-source, Pusher-compatible WebSockets server built on uWebSockets.js for Node.js. It enables self-hosted real-time event b… | 27 | 5633 | active |
| riverqueue/river River is a Go library providing a fast, reliable background job queue backed by PostgreSQL or SQLite, with transactional enqueueing so jobs… | 94 | 5604 | active |
| Proto.Actor Proto.Actor is an ultra-fast, cross-platform actor framework for Go, C#/.NET, and Java/Kotlin for building distributed, message-driven syst… | 57 | 5492 | active |
| Bogdanp/dramatiq Dramatiq is a fast and reliable distributed background task processing library for Python 3.10+. It uses an actor-based API with RabbitMQ o… | 86 | 5308 | active |
| fluvio-community/fluvio Fluvio is a distributed data streaming engine written in Rust that combines a Kafka-like event streaming platform with the Stateful DataFlo… | 79 | 5247 | active |
| blinker-iot/blinker-library Blinker is an IoT solution library for embedded hardware such as Arduino, ESP8266, and ESP32, providing device-side connectivity via WiFi, … | 67 | 5194 | active |
| Mikaelemmmm/go-zero-looklook A full-stack microservices reference project built on the go-zero framework in Go, demonstrating best practices with API/RPC/MQ services an… | 23 | 5193 | active |
| pgmq/pgmq pgmq is a lightweight message queue built on PostgreSQL, providing SQS/RSMQ-like semantics via a Postgres extension and a Rust client crate… | 89 | 5112 | active |
| akkadotnet/akka.net Akka.NET is an idiomatic .NET port of the Akka toolkit implementing the actor model for building highly concurrent, distributed, and fault-… | 99 | 5080 | active |
| dotnet/MQTTnet MQTTnet is a high-performance .NET library implementing the MQTT protocol (up to version 5), providing both an MQTT client and an embedded … | 87 | 5062 | active |
| WuKongIM/WuKongIM WuKongIM is a high-performance, channel-oriented instant messaging server written in Go that handles message persistence, replication, orde… | 90 | 4925 | active |
| AsamK/signal-cli signal-cli is an unofficial command-line, JSON-RPC, and D-Bus interface for the Signal messenger, supporting registering, verifying, sendin… | 97 | 4887 | active |
| nanomsg/nng NNG (nanomsg-next-generation) is a lightweight, broker-less messaging library in C implementing scalability protocols like pub/sub, request… | 95 | 4660 | stable |
| ergo-services/ergo Ergo Framework is a Go framework implementing the actor model with network transparency, inspired by Erlang/OTP design patterns. It provide… | 78 | 4633 | active |
| php-amqplib/php-amqplib php-amqplib is a pure PHP implementation of the AMQP 0-9-1 protocol client, primarily used to communicate with RabbitMQ message brokers. It… | 64 | 4602 | active |
| apache/rocketmq-externals The Apache RocketMQ externals repository is the community home for incubating ecosystem projects around the RocketMQ message broker, such a… | 71 | 4601 | active |
| apache/iggy Apache Iggy is a high-performance, persistent message streaming platform written in Rust, supporting TCP, QUIC, HTTP, and WebSocket transpo… | 86 | 4545 | active |
| blinker-iot/blinker-js Blinker is a JavaScript/TypeScript SDK for connecting hardware devices (like Raspberry Pi) to the Blinker IoT platform via MQTT or local ne… | 38 | 4379 | active |
| jamesmh/coravel Coravel is a near-zero configuration .NET library that provides task/job scheduling, in-memory queuing, caching, event broadcasting, and ma… | 37 | 4287 | active |
| zendesk/maxwell Maxwell's Daemon is a change data capture (CDC) application that reads MySQL binlogs and emits row-level changes as JSON to Kafka, Kinesis,… | 96 | 4258 | active |
| laravel/horizon Laravel Horizon is a first-party Laravel package providing a dashboard and code-driven configuration for Laravel Redis queues. It lets team… | 98 | 4165 | stable |
| 1technophile/OpenMQTTGateway OpenMQTTGateway is an open-source firmware that turns ESP8266/ESP32 boards (and computers) into a unified MQTT gateway bridging many protoc… | 74 | 4082 | active |
| bee-queue/bee-queue Bee-Queue is a simple, fast, robust job/task queue library for Node.js backed by Redis. It is designed for distributed worker pools handlin… | 73 | 4036 | active |
| emitter-io/emitter Emitter is a distributed, high-performance publish-subscribe messaging platform built on the MQTT protocol, written in Go. It supports mess… | 58 | 4004 | active |
| tulios/kafkajs KafkaJS is a modern, dependency-free Apache Kafka client library for Node.js written in pure JavaScript. It provides producer and consumer … | 23 | 4002 | stable |
| JeremyLiao/LiveEventBus LiveEventBus is an Android event bus library built on LiveData that provides lifecycle-aware message passing. It supports sticky events, de… | 32 | 3983 | stable |
| oban-bg/oban Oban is a robust background job processing library for Elixir, backed by PostgreSQL, SQLite3, and MySQL, with transactional job insertion, … | 95 | 3957 | stable |
| timgit/pg-boss pg-boss is a Node.js job queue built on top of PostgreSQL, using SKIP LOCKED to provide exactly-once delivery and reliable background proce… | 95 | 3901 | stable |
| dora-rs/dora Dora is a Rust-based dataflow middleware framework for building real-time robotics and AI applications, where applications are modeled as d… | 87 | 3900 | active |
| binux/pyspider pyspider is a powerful web crawler (spider) system written in Python with a built-in WebUI for script editing, task monitoring, project man… | 10 | 16774 | maintenance |
| pika/pika Pika is a pure-Python client library implementing the AMQP 0-9-1 protocol, including RabbitMQ extensions. It provides multiple connection a… | 98 | 3878 | stable |
| amqp-node/amqplib amqplib is an AMQP 0-9-1 library and client for Node.js, providing both low-level protocol machinery and a high-level client API. It suppor… | 86 | 3847 | stable |
| OpenHFT/Chronicle-Queue Chronicle Queue is a Java library providing microsecond-latency, persisted messaging that stores every message to disk in an append-only, z… | 98 | 3797 | stable |
| OptimalBits/bull Bull is a Redis-based job and message queue library for Node.js supporting priorities, scheduling, retries, and rate limiting. It is now in… | 72 | 16248 | maintenance |
| nikoksr/notify Notify is a Go library that provides a simple, unified API for sending notifications to many messaging services such as Telegram, Slack, Di… | 86 | 3759 | active |
| tarantool/tarantool Tarantool is an in-memory computing platform combining a fast NoSQL database with a Lua application server. It stores data in RAM with WAL … | 97 | 3665 | stable |
| vernemq/vernemq VerneMQ is a high-performance, distributed MQTT message broker built on Erlang/OTP with master-less clustering for horizontal scalability a… | 86 | 3624 | stable |
| AxonIQ/AxonFramework Axon Framework is a JVM framework for building evolutionary, message-driven microservices based on Domain-Driven Design, CQRS, and Event So… | 99 | 3614 | stable |
| redis/ioredis ioredis is a robust, performance-focused, full-featured Redis client for Node.js written in TypeScript. It supports Redis Cluster, Sentinel… | 97 | 15332 | maintenance |
| primus/eventemitter3 EventEmitter3 is a high-performance JavaScript event emitter that is API-compatible with Node.js's built-in EventEmitter while also running… | 71 | 3538 | stable |
| olric-data/olric Olric is a distributed, in-memory key/value store and cache written entirely in Go. It can be embedded as a Go library or run as a standalo… | 91 | 3490 | active |
| svix/svix-webhooks Svix is an open-source, enterprise-ready webhooks-as-a-service platform written in Rust that lets developers send webhooks with a single AP… | 95 | 3371 | active |
page 1 / 6 next →