오픈 소스 메시지 큐 및 스트리밍, 테스트됨

실시간 분산 메시징 플랫폼

테스트 결과: 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 Era의 IoT를 위한 확장 가능한 분산 MQTT Message Broker

테스트 결과: 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분.

전 세계 라디오를 터미널에서 바로 재생합니다.

테스트 결과: 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 - 최신 C++ 툴킷, 고속 프로세스 간 통신(IPC)을 위한

테스트 결과: 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분.

C와 Tokyo Cabinet으로 작성한 httpsqs처럼 Go와 goleveldb로 작성한 간단한 HTTP 메시지 큐

테스트 결과: 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분.

[읽기 전용] Symfony용 메시지 큐 번들. RabbitMQ, Amazon SQS, Redis, 서비스 버스, 비동기 이벤트, 메시지 큐를 통한 원격 프로시저 호출 그리고 훨씬 더 많은 것

테스트 결과: 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용 빠르고 가벼운 Logs, 메트릭 및 트레이스 프로세서

테스트 결과: 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분.

기본 원리부터 구축한 분산 log 스트리밍 엔진

테스트 결과: 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는 Workflow-As-Code 마이크로서비스 오케스트레이션 플랫폼입니다. 복원력 있고 내결함성이 있으며 확장 가능한 장기 실행 프로세스를 구축하기 위한 오케스트레이션 코딩 프레임워크와 서비스를 제공합니다.

테스트 결과: 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분.

오픈 소스 및 엔터프라이즈급 웹훅 서비스

테스트 결과: 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를 위한 메시지 큐, 작업 큐, 브로드캐스팅, WebSockets 패키지입니다. 개발 리포지토리 - 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 미디어 서버

테스트 결과: 검증할 수 없었습니다. 어디서 멈췄는지는 log에서 볼 수 있습니다. 8분.

AI 시대를 위한 커뮤니케이션 인프라: 단일 바이너리, 단일 브로커, 단일 스토리지 계층, 모든 프로토콜

테스트 결과: 검증할 수 없었습니다. 어디서 멈췄는지는 log에서 볼 수 있습니다. 21분.

개발자가 이동 중인 데이터를 수집하고 변환하여 반응성이 뛰어난 데이터 집약적 애플리케이션을 구동할 수 있게 하는 이벤트 스트림 처리

테스트 결과: 검증할 수 없었습니다. 어디서 멈췄는지는 log에서 볼 수 있습니다. 87분.

스트림 처리 및 복합 이벤트 처리 엔진

테스트 결과: 검증할 수 없었습니다. 어디서 멈췄는지는 log에서 볼 수 있습니다. 87분.