Filas de mensagens e streaming de código aberto, testado

Plataforma de mensageria distribuída em tempo real

O que o teste encontrou: 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.

Um pipeline de dados de observabilidade de alta performance.

O que o teste encontrou: 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 alta performance para NATS.io, o sistema de mensageria nativo de nuvem e edge.

O que o teste encontrou: 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.

Construindo aplicativos orientados a eventos do jeito fácil em Go.

O que o teste encontrou: 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 IA agêntica. Ingira, transforme e sirva streams de eventos continuamente, em tempo real, em escala.

O que o teste encontrou: 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 mensagens para Python.

O que o teste encontrou: 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.

Uma biblioteca leve de processamento de fluxo para Go.

O que o teste encontrou: Go 1.22.2 installed, project builds with go build and passes all 100+ tests with go test -count=1 ./... 20 minutos.

Um motor de processamento de fluxo em Python inspirado no Yahoo! Pipes

O que o teste encontrou: 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 processamento em segundo plano para Rust, com segurança de tipos, extensível e de alto desempenho

O que o teste encontrou: 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.

Eficiente, fácil de usar e rápido PHP JSON stream parser

O que o teste encontrou: All 841 PHPUnit tests pass on PHP 8.0.30 with dependencies installed via Composer. 4 minutos.

Biblioteca de rede orientada a eventos, rápida e fácil de usar.

O que o teste encontrou: 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.

Extensões reativas de custo zero e type-safe para Rust. Suporta contextos single-threaded de alta performance (Local) e thread-safe (Shared). Pronto para WASM...

O que o teste encontrou: 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 para construção de Microsserviços Orientados a Eventos

O que o teste encontrou: 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 - Broker de Mensagens MQTT Distribuído e Escalável para IoT na Era 5G

O que o teste encontrou: 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.

Filas assíncronas simples

O que o teste encontrou: 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.

Construa plataformas que misturem de forma flexível os paradigmas de processamento SQL, batch e stream.

O que o teste encontrou: 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.

um sistema de mensagens pub-sub distribuído, rápido e simples (mq)

O que o teste encontrou: Jafka 3.0.8 builds from source, all 70 unit tests pass, and the broker starts on port 9092 accepting TCP connections. 9 minutos.

Toque qualquer rádio ao redor do mundo diretamente do terminal:zap:

O que o teste encontrou: 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.

Um cliente C para NATS

O que o teste encontrou: 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 de ferramentas em C++ moderno para comunicação entre processos (IPC) de alta velocidade.

O que o teste encontrou: 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.

Um Runtime SDR Assíncrono para Arquiteturas Heterogêneas

O que o teste encontrou: 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.

Uma simples fila de mensagens HTTP escrita em Go com goleveldb, assim como httpsqs escrito em C com Tokyo Cabinet.

O que o teste encontrou: 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.

Barramento de mensagens assíncrono simples em Go

O que o teste encontrou: 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.

O framework sem servidor projetado especificamente para aplicativos de streaming de eventos.

O que o teste encontrou: Go 1.25.0 installed, project builds, controller test suite passes all 57 specs using real Kubernetes envtest binaries. 8 minutos.

A mais simples fila de mensagens em memória, distribuída e agnóstica de armazenamento para seu programa Go concorrente.

O que o teste encontrou: 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.

[READ-ONLY] Bundle de fila de mensagens para Symfony. RabbitMQ, Amazon SQS, Redis, Service bus, Eventos assíncronos, RPC over MQ e muito mais

O que o teste encontrou: 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.

Processador de Logs, Métricas e Traces rápido e leve visando Linux, BSD, OSX e Windows

O que o teste encontrou: 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 distribuído de streaming de logs construído do zero.

O que o teste encontrou: 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 é uma biblioteca de processamento de streams reativos de alta performance, escrita em C++ e Python.

O que o teste encontrou: 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 Python assíncrono para serviços orientados a eventos. Um cliente leve para Kafka, RabbitMQ, NATS, Redis e MQTT com acesso completo aos recursos...

O que o teste encontrou: 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 processamento de fluxos baseado em grafos com latência ultrabaixa

O que o teste encontrou: 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.

Fila de Mensagens Simples do Redis

O que o teste encontrou: 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 - Uma caixa de ferramentas IoT (Industrial) de autosserviço para permitir que usuários não técnicos conectem, analisem e explorem fluxos de...

O que o teste encontrou: 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.

Fila de jobs de alta performance para Bun. SQLite por padrão, PostgreSQL multi-broker quando você escala. DLQ, cron, backups SQLite S3 e MCP nativo. Sem Redis.

O que o teste encontrou: 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.

Um sistema moderno de fila de mensagens de código aberto e alto desempenho

O que o teste encontrou: BlazingMQ broker, CLI tool, and storage tool binaries are built and functional with 212/212 unit tests passing. 75 minutos.

blog de aprendizado do flink.

O que o teste encontrou: 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 mensagens estilo Kafka em Go. Construído sobre NATS. Binário único, sem JVM, sem ZooKeeper.

O que o teste encontrou: 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 é uma plataforma de orquestração de microsserviços Workflow-As-Code que oferece um framework de codificação de orquestração e serviço para construir...

O que o teste encontrou: 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.

O serviço de webhooks de código aberto e pronto para empresas.

O que o teste encontrou: 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.

Pacotes de Message Queue, Job Queue, Broadcasting, WebSockets para PHP, Symfony, Laravel, Magento. DEVELOPMENT REPOSITORY - fornecido por Forma-Pro

O que o teste encontrou: 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.

Kurento WebRTC Media Server

O que o teste encontrou: não foi possível verificar; o log mostra onde ele parou. 8 minutos.

Infraestrutura de comunicação para a era da IA: um binário, um broker, uma camada de armazenamento, qualquer protocolo

O que o teste encontrou: não foi possível verificar; o log mostra onde ele parou. 21 minutos.

Processamento de fluxo de eventos para desenvolvedores coletarem e transformarem dados em movimento para alimentar aplicativos responsivos e intensivos em...

O que o teste encontrou: não foi possível verificar; o log mostra onde ele parou. 87 minutos.

Motor de Processamento de Fluxos e de Eventos Complexos

O que o teste encontrou: não foi possível verificar; o log mostra onde ele parou. 87 minutos.