Colas de mensajes y streaming de código abierto, probados

Una plataforma de mensajería distribuida en tiempo real

Lo que encontró la prueba: All 10 NSQ daemon and utility binaries compile and run on linux/amd64 with Go 1.25.14; 18 test targets pass under both normal and race-detection modes; the live daemon cluster handles publish/stat operations correctly. 6 minutos.

Un canal de datos de observabilidad de alto rendimiento.

Lo que encontró la prueba: A preserved Vector binary reports version 0.59.0-dev-custom-3ce1054, validates a YAML config, and successfully processed three sentinel log records through demo_logs, remap, and console with no stderr output. 78 minutos.

Servidor de alto rendimiento para NATS.io, el sistema de mensajería nativo de la nube y el edge.

Lo que encontró la prueba: After installing Go 1.26.8, the server builds, reports v2.16.0-dev, serves /healthz with HTTP 200 while JetStream is enabled, completes real pub/sub and JetStream round trips, and exits 0 on SIGTERM; the targeted regression suites passed 37 tests with zero failures. 76 minutos.

Construye aplicaciones orientadas a eventos de manera fácil en Go.

Lo que encontró la prueba: The Watermill Go library builds and its full test suite passes; the quickstart and realtime-feed examples run end-to-end against a real Kafka 3.7.2 broker running inside this container, consuming and producing real messages on real topics. 21 minutos.

Plataforma de streaming de eventos para agentic AI. Ingiere, transforma y sirve flujos de eventos en tiempo real, a escala, de forma continua.

Lo que encontró la prueba: RisingWave 3.2.0-alpha builds from source, runs in single-node playground mode, and serves PostgreSQL-wire-protocol SQL queries on port 4566 with full DDL, DML, and materialized view support. 57 minutos.

Biblioteca de mensajería para Python.

Lo que encontró la prueba: kombu 5.7.0a1 is installed in a /tmp/venv virtual environment with all core and optional transport dependencies (redis, mongodb, sqs, azure, gcpubsub, pyro, yaml, msgpack, sqlalchemy, pgmq, consul, zookeeper) and all 2086 unit tests pass on Python 3.12.3. 5 minutos.

Una biblioteca ligera de procesamiento de flujos para Go

Lo que encontró la prueba: Go 1.22.2 installed, project builds with go build and passes all 100+ tests with go test -count=1 ./... 20 minutos.

Un motor de procesamiento de flujos en Python basado en Yahoo! Pipes

Lo que encontró la prueba: All 903 tests pass, the `run-pipe` CLI outputs correct results for demo/simple1 pipelines, and the compile/gen-config/codegen tools regenerate successfully with ruff 0.16.5 formatting. 26 minutos.

Biblioteca de procesamiento en segundo plano para Rust, con seguridad de tipos, extensible y de alto rendimiento.

Lo que encontró la prueba: The apalis workspace builds, all 127 tests pass (apalis: 18 tests, apalis-core: 86 tests, apalis-workflow: 9 tests, plus integration and doc-tests), and in-memory-backend examples (basic, deps-injection, unique-jobs-example) execute end-to-end without error. 8 minutos.

Analizador de flujo JSON en PHP eficiente, fácil de usar y rápido.

Lo que encontró la prueba: All 841 PHPUnit tests pass on PHP 8.0.30 with dependencies installed via Composer. 4 minutos.

Biblioteca de red orientada a eventos, rápida y fácil de usar.

Lo que encontró la prueba: The crate message-io v0.19.0 compiles without errors; all 85 tests pass across TCP, framed-TCP, UDP, and WebSocket transports; the ping-pong example runs end-to-end verifying real bidirectional socket communication. 2 minutos.

Extensiones Reactivas de costo cero y seguras para Rust. Soporta contextos de alto rendimiento de un solo hilo (Local) y seguros para hilos (Shared). Listo...

Lo que encontró la prueba: Rust 1.99.0 was installed, rxRust v1.0.0-rc.5 compiles and all tests pass (452 unit, 29 integration, 190 doctests). 1 minuto.

Framework for building Event-Driven Microservices

Lo que encontró la prueba: Spring Cloud Stream 5.1.0-SNAPSHOT compiles, installs and passes 958 tests (0 failures) across core, kafka, kafka-streams, pulsar and schema-registry modules; a real RabbitMQ 3.12.1 broker runs locally and serves AMQP and its management API; only the Rabbit binder integration suite cannot run because its... 62 minutos.

MQTT Server/MQTT Broker - Escalable distribuido MQTT Message Broker para IoT en la era 5G

Lo que encontró la prueba: rmqtt/0.25.0 MQTT broker built from source with Rust 1.99.0 on Ubuntu 24.04 x86_64. Release binary at target/release/rmqttd (31 MB). Broker starts on ports 1883 (MQTT), 8883 (MQTT/TLS), 6060 (HTTP API), 8080 (WS), 8443 (WSS), 9443 (QUIC), 11883 (internal), 5363 (gRPC). MQTT v3.1.1 connections, QoS0/QoS1 pub/sub... 25 minutos.

Colas Asíncronas Simples

Lo que encontró la prueba: SAQ installs in editable mode with all extras, its 298-test suite passes against live Redis and Postgres servers built from source in this container, and a running example worker processed a real job to completion (result 42) while its web UI answered HTTP 200. 8 minutos.

Crea plataformas que combinen de manera flexible los paradigmas de procesamiento SQL, por lotes y en streaming.

Lo que encontró la prueba: Go toolchain, etcd, and the 37 non-rocksdb packages build cleanly; 313 tests pass; a real etcd + gazette serve broker accepted gazctl journal creation, append, and read round-trips, and persisted decodable fragments to the file store; only the RocksDB-backed consumer-store packages remain unbuildable for lack of... 37 minutos.

un sistema de mensajería distribuido de publicación-suscripción rápido y simple (mq)

Lo que encontró la prueba: Jafka 3.0.8 builds from source, all 70 unit tests pass, and the broker starts on port 9092 accepting TCP connections. 9 minutos.

Reproduce cualquier radio del mundo directamente desde la terminal:zap:

Lo que encontró la prueba: radio-active 4.0.2 installs, all 16 tests pass, the CLI launches with --version and --help, searches the radio-browser API, and gracefully handles missing last station data. 3 minutos.

Un cliente en C para NATS

Lo que encontró la prueba: The cnats library built, installed to /work/repo/install, and its full 333-test suite passed against a real nats-server v2.15.1, with live publish/subscribe delivering 3 messages through the examples and an installed-library consumer program initializing with version 3.15.0-beta. 14 minutos.

Flow-IPC - Kit moderno de C++ para comunicación entre procesos de alta velocidad (IPC)

Lo que encontró la prueba: Project builds from source with Conan dependencies; flow library unit tests (15/15), IPC core link test, IPC transport structured link test, and IPC SHM unit tests (53/56) pass on real hardware with real IPC primitives. 55 minutos.

Un entorno de ejecución asíncrono de SDR para arquitecturas heterogéneas

Lo que encontró la prueba: FutureSDR v0.8.0 builds and tests pass on Rust nightly 1.101.0; flowgraph runtime executes correctly with the minimal example, control port listens on 127.0.0.1:1337, and blocks initialize/run/terminate as expected. 15 minutos.

Una cola de mensajes HTTP simple escrita en Go con goleveldb, igual que httpsqs escrita en C con Tokyo Cabinet.

Lo que encontró la prueba: httpmq v0.5 compiled from source with Go 1.22.4, runs as an HTTP server on port 1218 using LevelDB, and all documented queue operations (put, get, status, view, reset) work correctly. 4 minutos.

Bus de mensajes asíncrono simple en Go

Lo que encontró la prueba: Go 1.27.3 toolchain installed under /home/runner/go-toolchain; unit/race/vet/staticcheck suites pass; shutdown HTTP example served 202 on POST /signup, logged the handler, and exited cleanly on SIGTERM. 6 minutos.

El framework serverless diseñado específicamente para aplicaciones de streaming de eventos.

Lo que encontró la prueba: Go 1.25.0 installed, project builds, controller test suite passes all 57 specs using real Kubernetes envtest binaries. 8 minutos.

La cola de mensajes en memoria y distribuida más simple, independiente del almacenamiento, para tu programa Go concurrente.

Lo que encontró la prueba: VarMQ builds and all 93 tests pass across 7 modules (config, distributed, job, main, metrics, mux, queue, workers, and internal components); benchmarks also execute successfully. 2 minutos.

[Solo lectura] Bundle de cola de mensajes para Symfony. RabbitMQ, Amazon SQS, Redis, bus de servicios, eventos asíncronos, RPC sobre MQ y mucho más.

Lo que encontró la prueba: composer install completed with 152 packages; unit suite passes 87/87 and functional suite passes 38/38 using the file transport with real message send/consume/ack; the Symfony console app boots and enqueue:setup-broker prints 'Broker set up'. 35 minutos.

Procesador rápido y ligero de logs, métricas y trazas para Linux, BSD, OSX y Windows

Lo que encontró la prueba: Fluent Bit v5.1.3 builds from source. Binary launches at /work/repo/build/bin/fluent-bit. 96/97 internal tests pass; the flb-it-network IPv6 test fails because IPv6 is disabled in the container. 36 minutos.

Motor de transmisión de logs distribuido construido desde primeros principios.

Lo que encontró la prueba: A 3-node Walrus cluster runs with Raft consensus (node 1 Leader, nodes 2 and 3 Followers), all three nodes accept topic registration and message put/get operations, with full 3-node membership in Raft metrics. 64 minutos.

csp es una biblioteca de procesamiento reactivo de flujos de alto rendimiento, escrita en C++ y Python.

Lo que encontró la prueba: csp 0.19.1 installed from PyPI into a venv, ran the bid-ask spread example producing correct output, and 1600/1628 tests pass after installing tzdata, anywidget, and python-rapidjson. 38 minutos.

framework asíncrono de Python para servicios basados en eventos. Un cliente ligero para Kafka, RabbitMQ, NATS, Redis y MQTT con acceso completo a las funciones...

Lo que encontró la prueba: FastStream 0.7.7 is installed and all in-memory test suites pass: 4526 non-connected tests pass across Kafka, RabbitMQ, NATS, Redis, Confluent, and MQTT brokers, with CLI, ASGI, and AsyncAPI documentation generation working correctly. 42 minutos.

framework de procesamiento de flujos basado en grafos de ultra baja latencia

Lo que encontró la prueba: The core Rust crate wingfoil v9.0.0 builds, all 477 tests pass, and the hello_graph example runs correctly producing historical and realtime output. 8 minutos.

Cola de mensajes simple de Redis

Lo que encontró la prueba: RSMQ 0.13.0 installed and all 93 tests pass against Redis 7.2.0 on 127.0.0.1:6379; send/receive/delete verified via real Redis. 6 minutos.

Apache StreamPipes - Una caja de herramientas IoT de autoservicio (Industrial) para permitir que usuarios no técnicos conecten, analicen y exploren flujos de...

Lo que encontró la prueba: Maven builds all non-integration modules successfully, 1073 backend unit tests pass with zero failures, the Angular UI builds to dist, and the backend jar starts and initializes Tomcat on port 8030 before stopping because the CouchDB service is not available in this container. 45 minutos.

Cola de trabajos de alto rendimiento para Bun. SQLite por defecto, multi-broker PostgreSQL cuando escalas. DLQ, cron, copias de seguridad SQLite S3 y MCP...

Lo que encontró la prueba: Bunqueue v2.9.5 is fully installed and operational: the library compiles, all 8740 active tests pass, typecheck is clean, the embedded queue processes jobs end-to-end, and the TCP/HTTP server starts and binds on the configured ports. 51 minutos.

Un moderno sistema de colas de mensajes de código abierto y alto rendimiento

Lo que encontró la prueba: BlazingMQ broker, CLI tool, and storage tool binaries are built and functional with 212/212 unit tests passing. 75 minutos.

Blog de aprendizaje de flink.

Lo que encontró la prueba: flink-learning builds successfully with 94/94 modules. 7 unit tests pass in flink-learning-common. Integration tests requiring Kafka/Cassandra/Redis/DingTalk cannot execute without external services. 52 minutos.

Streaming de mensajes estilo Kafka en Go. Construido sobre NATS. Un solo binario, sin JVM, sin ZooKeeper.

Lo que encontró la prueba: The binary builds, all unit tests pass, and the server starts with embedded NATS, binds to port 9292, elects itself metadata leader, and logs normal operation. 21 minutos.

iWF es una plataforma de orquestación de microservicios Workflow-As-Code que ofrece un framework de codificación de orquestación y un servicio para construir...

Lo que encontró la prueba: iwf-server binary builds, all 23 unit tests pass, blobstore integration tests pass against moto S3 mock, and the server starts on port 8801 connected to a local Temporal dev server, responding with HTTP 200 on healthcheck and workflow start API. 16 minutos.

El servicio de webhooks de código abierto y listo para empresas.

Lo que encontró la prueba: Python client library installs and passes all applicable unit tests (31/31), webhook verification module works end-to-end, CLI tool runs correctly via npx and produces valid signatures. 13 minutos.

Paquetes de cola de mensajes, cola de trabajos, broadcasting y WebSockets para PHP, Symfony, Laravel y Magento. REPOSITORIO DE DESARROLLO: proporcionado por...

Lo que encontró la prueba: PHP 8.2.13 and Composer 2.10.3 installed; all 169 Composer dependencies resolved and vendor autoloader generated; RdKafkaConnectionFactory input validation fixed to throw LogicException before librdkafka check; core enqueue test suite passes 1153/1154 tests; full 3136-test suite runs with 134 errors and 11 failures... 17 minutos.

Servidor de medios Kurento WebRTC

Lo que encontró la prueba: no se pudo verificar; el log muestra dónde se detuvo. 8 minutos.

Infraestructura de comunicación para la era de la IA: un binario, un broker, una capa de almacenamiento, cualquier protocolo.

Lo que encontró la prueba: no se pudo verificar; el log muestra dónde se detuvo. 21 minutos.

Procesamiento de flujos de eventos para desarrolladores: recopilar y transformar datos en movimiento para impulsar aplicaciones con capacidad de respuesta e...

Lo que encontró la prueba: no se pudo verificar; el log muestra dónde se detuvo. 87 minutos.

Motor de procesamiento de flujos y eventos complejos

Lo que encontró la prueba: no se pudo verificar; el log muestra dónde se detuvo. 87 minutos.