Open source message queues and streaming, tested

A realtime distributed messaging platform

What the test found: NSQ v1.3.0 builds on Go 1.26.8, all 11 test packages pass (0 failures), and nsqlookupd+nsqd boot, accept HTTP publishes, and deliver messages end-to-end. 6 minutes.

A high-performance observability data pipeline.

What the test found: The project compiles, the binary runs and processes real data end-to-end: demo_logs source reads events, console and blackhole sinks receive them, and 499 unit tests pass in 26 seconds. 3 pre-existing tests fail due to a missing external secrets-exec binary. 71 minutes.

High-Performance server for NATS.io, the cloud and edge native messaging system.

What the test found: NATS server v2.16.0-dev builds, launches, binds port 4222, and passes real client-server integration tests including cluster pub/sub and auth. 15 minutes.

Building event-driven applications the easy way in Go.

What the test found: Watermill Go library builds and all tests pass with the race detector enabled across all packages including cqrs, delay, fanin, forwarder, metrics, requestreply, requeuer, gochannel, sync, message, middleware, subscriber, internal, internal/publisher, and the root watermill package. 3 minutes.

Event streaming platform for agentic AI. Continuously ingest, transform, and serve event streams in real time, at scale.

What the test found: 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.

Messaging library for Python.

What the test found: 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.

A lightweight stream processing library for Go

What the test found: Go 1.22.2 installed, project builds with go build and passes all 100+ tests with go test -count=1 ./... 20 minutes.

A Python stream processing engine modeled after Yahoo! Pipes

What the test found: 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.

Type-safe, extensible, and high-performance background processing library for Rust

What the test found: 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.

Fast and Lightweight Logs, Metrics and Traces processor for Linux, BSD, OSX and Windows

What the test found: 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.

🦭 Distributed log streaming engine built from first principles

What the test found: 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.

Asynchronous Python framework for event-driven services. A thin client for Kafka, RabbitMQ, NATS, Redis and MQTT with full access to native broker features...

What the test found: 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.

Redis Simple Message Queue

What the test found: 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.

A modern high-performance open source message queuing system

What the test found: BlazingMQ broker, CLI tool, and storage tool binaries are built and functional with 212/212 unit tests passing. 75 minutes.

flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL...

What the test found: The full 94-module Maven reactor builds successfully with all compilation errors fixed; 78 JARs are produced; the test suite runs with only 3 pre-existing timezone-dependent assertion failures in DateUtilTests and 1 pre-existing Kafka-required error in SqlSubmitTest; all other tests pass. 53 minutes.

Kafka-style message streaming in Go. Built on NATS. Single binary, no JVM, no ZooKeeper.

What the test found: 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.

The open source and enterprise-ready webhooks service 🦀

What the test found: 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.

Message Queue, Job Queue, Broadcasting, WebSockets packages for PHP, Symfony, Laravel, Magento. DEVELOPMENT REPOSITORY - provided by Forma-Pro

What the test found: 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.

Communication infrastructure for the AI era, one binary, one broker, one storage layer, any protocol

What the test found: could not be verified; the log shows where it stopped. 21 minutes.

🦀 event stream processing for developers to collect and transform data in motion to power responsive data intensive applications.

What the test found: could not be verified; the log shows where it stopped. 87 minutes.

Stream Processing and Complex Event Processing Engine

What the test found: could not be verified; the log shows where it stopped. 87 minutes.