Files d’attente de messages et streaming open source, testés

Une plateforme de messagerie distribuée en temps réel

Ce que le test a constaté : 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 minutes.

Un pipeline de données d'observabilité haute performance.

Ce que le test a constaté : 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 minutes.

Serveur haute performance pour NATS.io, le système de messagerie natif cloud et edge.

Ce que le test a constaté : 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 minutes.

Créer des applications événementielles en toute simplicité en Go.

Ce que le test a constaté : 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 minutes.

Plateforme de streaming d'événements pour l'IA agentique. Ingérez, transformez et servez en continu des flux d'événements en temps réel, à grande échelle.

Ce que le test a constaté : 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 minutes.

Bibliothèque de messagerie pour Python.

Ce que le test a constaté : 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 minutes.

Une bibliothèque légère de traitement de flux pour Go

Ce que le test a constaté : Go 1.22.2 installed, project builds with go build and passes all 100+ tests with go test -count=1 ./... 20 minutes.

Un moteur de traitement de flux en Python inspiré de Yahoo! Pipes

Ce que le test a constaté : 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 minutes.

Bibliothèque de traitement en arrière-plan sûre au niveau des types, extensible et haute performance pour Rust.

Ce que le test a constaté : 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 minutes.

Analyseur de flux JSON en PHP, efficace, facile à utiliser et rapide.

Ce que le test a constaté : All 841 PHPUnit tests pass on PHP 8.0.30 with dependencies installed via Composer. 4 minutes.

Bibliothèque réseau rapide et facile à utiliser, pilotée par événements.

Ce que le test a constaté : 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 minutes.

Extensions réactives à coût nul et sûres au niveau des types pour Rust. Prend en charge les contextes monothreadés haute performance (Local) et thread-safe...

Ce que le test a constaté : Rust 1.99.0 was installed, rxRust v1.0.0-rc.5 compiles and all tests pass (452 unit, 29 integration, 190 doctests). 1 minute.

Framework pour créer des microservices événementiels

Ce que le test a constaté : 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 minutes.

Serveur MQTT/Broker MQTT - Broker de messages MQTT distribué et évolutif pour l'IdO à l'ère de la 5G

Ce que le test a constaté : 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 minutes.

Files d'attente asynchrones simples

Ce que le test a constaté : 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 minutes.

Créez des plateformes qui combinent de manière flexible les paradigmes de traitement SQL, par lots et en flux.

Ce que le test a constaté : 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 minutes.

Un système de messagerie distribué de publication-abonnement, rapide et simple (mq)

Ce que le test a constaté : Jafka 3.0.8 builds from source, all 70 unit tests pass, and the broker starts on port 9092 accepting TCP connections. 9 minutes.

Écoutez n'importe quelle radio du monde entier directement depuis le terminal:zap:

Ce que le test a constaté : 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 minutes.

Un client C pour NATS

Ce que le test a constaté : 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 minutes.

Flow-IPC - Boîte à outils C++ moderne pour la communication inter-processus à haute vitesse (IPC)

Ce que le test a constaté : 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 minutes.

Un runtime SDR asynchrone pour architectures hétérogènes

Ce que le test a constaté : 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 minutes.

Une simple file d'attente de messages HTTP écrite en Go avec goleveldb, tout comme httpsqs écrite en C avec Tokyo Cabinet.

Ce que le test a constaté : 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 minutes.

Bus de messages asynchrone simple en Go

Ce que le test a constaté : 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 minutes.

Le framework serverless conçu spécifiquement pour les applications de streaming d'événements.

Ce que le test a constaté : Go 1.25.0 installed, project builds, controller test suite passes all 57 specs using real Kubernetes envtest binaries. 8 minutes.

La plus simple file de messages en mémoire et indépendante du stockage distribué pour votre programme Go concurrent

Ce que le test a constaté : 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 minutes.

[READ-ONLY] Bundle de file d'attente de messages pour Symfony. RabbitMQ, Amazon SQS, Redis, Service bus, Async events, RPC over MQ et bien plus encore.

Ce que le test a constaté : 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 minutes.

Processeur rapide et léger de Logs, métriques et traces pour Linux, BSD, OSX et Windows

Ce que le test a constaté : 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 minutes.

Moteur de streaming de logs distribué construit à partir des premiers principes.

Ce que le test a constaté : 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 minutes.

csp est une bibliothèque de traitement de flux réactif à haute performance, écrite en C++ et Python.

Ce que le test a constaté : 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 minutes.

Framework Python asynchrone pour des services événementiels. Un client léger pour Kafka, RabbitMQ, NATS, Redis et MQTT avec un accès complet aux...

Ce que le test a constaté : 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 minutes.

framework de traitement de flux basé sur un graphe à ultra faible latence

Ce que le test a constaté : 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 minutes.

Redis Simple Message Queue

Ce que le test a constaté : 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 minutes.

Apache StreamPipes - Une boîte à outils IoT (industrielle) en libre-service pour permettre aux utilisateurs non techniques de connecter, analyser et explorer...

Ce que le test a constaté : 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 minutes.

File d'attente de tâches haute performance pour Bun. SQLite par défaut, PostgreSQL multi-broker lorsque vous montez en charge. DLQ, cron, sauvegardes SQLite S3...

Ce que le test a constaté : 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 minutes.

Un système de file d'attente de messages moderne, haute performance et open source

Ce que le test a constaté : BlazingMQ broker, CLI tool, and storage tool binaries are built and functional with 212/212 unit tests passing. 75 minutes.

Blog d'apprentissage de flink

Ce que le test a constaté : 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 minutes.

Streaming de messages de type Kafka en Go. Construit sur NATS. Un seul binaire, pas de JVM, pas de ZooKeeper.

Ce que le test a constaté : 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 minutes.

iWF est une plateforme d'orchestration de microservices Workflow-As-Code offrant un framework de code d'orchestration et un service pour créer des processus...

Ce que le test a constaté : 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 minutes.

Le service de webhooks open source et prêt pour l'entreprise.

Ce que le test a constaté : 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 minutes.

Packages de file de messages, de file de tâches, de diffusion et de WebSockets pour PHP, Symfony, Laravel, Magento. DÉPÔT DE DÉVELOPPEMENT - fourni via...

Ce que le test a constaté : 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 minutes.

Kurento WebRTC Media Server

Ce que le test a constaté : n'a pas pu être vérifié ; le log montre où il s'est arrêté. 8 minutes.

Infrastructure de communication pour l'ère de l'AI: un binaire, un courtier, une couche de stockage, n'importe quel protocole.

Ce que le test a constaté : n'a pas pu être vérifié ; le log montre où il s'est arrêté. 21 minutes.

Traitement de flux d'événements pour les développeurs pour collecter et transformer des données en mouvement pour alimenter des applications réactives et...

Ce que le test a constaté : n'a pas pu être vérifié ; le log montre où il s'est arrêté. 87 minutes.

Moteur de traitement de flux et de traitement d'événements complexes

Ce que le test a constaté : n'a pas pu être vérifié ; le log montre où il s'est arrêté. 87 minutes.