オープンソースのメッセージキューとストリーミング、テスト済み

リアルタイム分散メッセージングプラットフォーム

テストでわかったこと: 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 分。

高性能な可観測性データパイプライン。

テストでわかったこと: 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 分。

NATS.io 向けの高性能サーバー。クラウドおよびエッジネイティブなメッセージングシステムです。

テストでわかったこと: 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 分。

Goでイベント駆動アプリケーションを簡単に構築

テストでわかったこと: 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 分。

エージェント型 AI 向けのイベントストリーミングプラットフォーム。イベントストリームをリアルタイムかつ大規模に継続的に取り込み、変換し、配信します。

テストでわかったこと: 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 分。

Python 用のメッセージングライブラリ。

テストでわかったこと: 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 分。

Go 向けの軽量ストリーム処理ライブラリ

テストでわかったこと: Go 1.22.2 installed, project builds with go build and passes all 100+ tests with go test -count=1 ./... 20 分。

Yahoo! Pipes をモデルにした Python ストリーム処理エンジン

テストでわかったこと: 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 分。

Rust 向けの型安全で拡張可能かつ高性能なバックグラウンド処理ライブラリ

テストでわかったこと: 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 分。

効率的で使いやすく高速な PHP JSON ストリームパーサー

テストでわかったこと: All 841 PHPUnit tests pass on PHP 8.0.30 with dependencies installed via Composer. 4 分。

高速で使いやすいイベント駆動型ネットワークライブラリ。

テストでわかったこと: 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 分。

Rust 向けのゼロコストかつ型安全な Reactive Extensions です。高性能なシングルスレッド（Local）とスレッドセーフな（Shared）コンテキストの両方をサポートしています。WASM と Tokio に対応しています。

テストでわかったこと: Rust 1.99.0 was installed, rxRust v1.0.0-rc.5 compiles and all tests pass (452 unit, 29 integration, 190 doctests). 1 分。

イベント駆動型マイクロサービスを構築するためのフレームワークです。

テストでわかったこと: 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 分。

MQTT Server/MQTT Broker: 5G 時代の IoT 向けスケーラブルな分散 MQTT メッセージブローカー

テストでわかったこと: 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 分。

シンプルな非同期キュー

テストでわかったこと: 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 分。

SQL、バッチ、ストリーム処理のパラダイムを柔軟に組み合わせるプラットフォームを構築します。

テストでわかったこと: 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 分。

高速でシンプルな分散型パブリッシュ/サブスクライブメッセージングシステム (mq)

テストでわかったこと: Jafka 3.0.8 builds from source, all 70 unit tests pass, and the broker starts on port 9092 accepting TCP connections. 9 分。

世界中のあらゆるラジオをターミナルから直接再生できます:zap:

テストでわかったこと: 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 分。

NATS 向けの C クライアント

テストでわかったこと: 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 分。

Flow-IPC - 高速なプロセス間通信（IPC）のためのモダン C++ ツールキット

テストでわかったこと: 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 分。

ヘテロジニアスなアーキテクチャのための非同期 SDR ランタイム

テストでわかったこと: 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 分。

Go で書かれ、goleveldb を使用したシンプルな HTTP メッセージキューで、C で書かれ Tokyo Cabinet を使用する httpsqs と同様です。

テストでわかったこと: 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 分。

Go によるシンプルな非同期メッセージバス

テストでわかったこと: 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 分。

イベントストリーミングアプリケーション向けに特化したサーバーレスフレームワーク。

テストでわかったこと: Go 1.25.0 installed, project builds, controller test suite passes all 57 specs using real Kubernetes envtest binaries. 8 分。

あなたの並行 Go プログラムのための、最もシンプルなインメモリかつ分散ストレージ非依存のメッセージキュー

テストでわかったこと: 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 分。

[READ-ONLY] Symfony 用のメッセージキューバンドル。RabbitMQ、Amazon SQS、Redis、Service bus、非同期イベント、MQ 経由の RPC、その他多数。

テストでわかったこと: 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 分。

高速かつ軽量なログ、メトリクス、トレースプロセッサ。Linux、BSD、OSX、Windows 対応。

テストでわかったこと: 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 分。

第一原理から構築された分散ログストリーミングエンジン

テストでわかったこと: 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 分。

csp は、C++ と Python で書かれた高性能なリアクティブストリーム処理ライブラリです。

テストでわかったこと: 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 分。

非同期 Python フレームワークで、イベント駆動型サービス向けです。Kafka、RabbitMQ、NATS、Redis、MQTT のシンクライアントで、ネイティブのブローカー機能に完全にアクセスでき、さらに AsyncAPI ドキュメント、インメモリテスト、オブザーバビリティを標準装備しています。

テストでわかったこと: 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 分。

超低遅延グラフベースのストリーム処理フレームワーク

テストでわかったこと: 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 分。

Redis シンプルメッセージキュー

テストでわかったこと: 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 分。

Apache StreamPipes: 非技術ユーザーが IoT データストリームを接続、分析、探索できるようにする、セルフサービスの (産業用) IoT ツールボックスです。

テストでわかったこと: 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 分。

Bun 向けの高性能ジョブキュー。デフォルトで SQLite、スケール時には PostgreSQL マルチブローカー。DLQ、cron、SQLite S3 バックアップ、ネイティブ MCP をサポート。Redis は不要です。

テストでわかったこと: 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 分。

モダンな高性能オープンソースメッセージキューイングシステム

テストでわかったこと: BlazingMQ broker, CLI tool, and storage tool binaries are built and functional with 212/212 unit tests passing. 75 分。

flink 学習ブログ。

テストでわかったこと: 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 分。

Go で実装された Kafka スタイルのメッセージストリーミング。NATS 上に構築。単一バイナリ、JVM 不要、ZooKeeper 不要。

テストでわかったこと: 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 分。

iWF は、ワークフロー・アズ・コードのマイクロサービス・オーケストレーション・プラットフォームであり、回復力があり、フォールトトレラントで、スケーラブルな長時間実行プロセスを構築するためのオーケストレーション・コーディング・フレームワークとサービスを提供しています。

テストでわかったこと: 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 分。

オープンソースでエンタープライズ対応の Webhook サービス

テストでわかったこと: 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 分。

PHP、Symfony、Laravel、Magento 向けのメッセージキュー、ジョブキュー、ブロードキャスティング、WebSocket パッケージ。開発リポジトリ - Forma-Pro 提供

テストでわかったこと: 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 分。

Kurento WebRTC メディアサーバー

テストでわかったこと: 検証できませんでした。どこで止まったかはログで確認できます。 8 分。

AI 時代の通信インフラ: 単一のバイナリ、単一のブローカー、単一のストレージ層、あらゆるプロトコル

テストでわかったこと: 検証できませんでした。どこで止まったかはログで確認できます。 21 分。

開発者向けのイベントストリーム処理は、移動中のデータを収集・変換して、応答性の高いデータ集約型アプリケーションを支えます。

テストでわかったこと: 検証できませんでした。どこで止まったかはログで確認できます。 87 分。

ストリーム処理および複雑なイベント処理エンジン

テストでわかったこと: 検証できませんでした。どこで止まったかはログで確認できます。 87 分。