Open-Source-Nachrichtenwarteschlangen und Streaming, getestet

Eine Echtzeit-Plattform für verteilte Nachrichtenübermittlung.

Was der Test ergab: 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 Minuten.

Eine Hochleistungs-Datenpipeline für Observability.

Was der Test ergab: 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 Minuten.

Hochleistungs-Server für NATS.io, das Cloud- und Edge-native Messaging-System.

Was der Test ergab: 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 Minuten.

Ereignisgesteuerte Anwendungen auf einfache Weise in Go erstellen.

Was der Test ergab: 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 Minuten.

Event-Streaming-Plattform für agentische KI. Kontinuierlich Event-Streams in Echtzeit und in großem Umfang erfassen, transformieren und bereitstellen.

Was der Test ergab: 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 Minuten.

Messaging-Bibliothek für Python.

Was der Test ergab: 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 Minuten.

Eine leichtgewichtige Stream-Processing-Bibliothek für Go

Was der Test ergab: Go 1.22.2 installed, project builds with go build and passes all 100+ tests with go test -count=1 ./... 20 Minuten.

Eine Python-Stream-Processing-Engine nach dem Vorbild von Yahoo! Pipes

Was der Test ergab: 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 Minuten.

Typsichere, erweiterbare und hochleistungsfähige Hintergrundverarbeitungsbibliothek für Rust

Was der Test ergab: 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 Minuten.

Efficient, easy-to-use, and fast PHP JSON stream parser

Was der Test ergab: All 841 PHPUnit tests pass on PHP 8.0.30 with dependencies installed via Composer. 4 Minuten.

Schnelle und einfach zu verwendende ereignisgesteuerte Netzwerkbibliothek.

Was der Test ergab: 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 Minuten.

Kostenlose und typsichere Reactive Extensions für Rust. Unterstützt sowohl leistungsstarke Single-Threaded- (Local) als auch thread-sichere (Shared) Kontexte...

Was der Test ergab: 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 zur Erstellung ereignisgesteuerter Microservices

Was der Test ergab: 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 Minuten.

MQTT Server/MQTT Broker - Skalierbarer verteilter MQTT Message Broker für IoT in der 5G-Ära

Was der Test ergab: 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 Minuten.

Einfache asynchrone Warteschlangen

Was der Test ergab: 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 Minuten.

Erstellen Sie Plattformen, die SQL-, Batch- und Stream-Verarbeitungsparadigmen flexibel mischen.

Was der Test ergab: 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 Minuten.

ein schnelles und einfaches verteiltes Publish-Subscribe-Nachrichtensystem (mq)

Was der Test ergab: Jafka 3.0.8 builds from source, all 70 unit tests pass, and the broker starts on port 9092 accepting TCP connections. 9 Minuten.

Spielen Sie beliebige Radios auf der ganzen Welt direkt vom Terminal aus:zap:

Was der Test ergab: 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 Minuten.

Ein C-Client für NATS

Was der Test ergab: 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 Minuten.

Flow-IPC - Modernes C++ Toolkit für schnelle Interprozesskommunikation (IPC)

Was der Test ergab: 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 Minuten.

Eine asynchrone SDR-Laufzeitumgebung für heterogene Architekturen

Was der Test ergab: 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 Minuten.

Eine einfache HTTP-Nachrichtenwarteschlange, geschrieben in Go mit goleveldb, genau wie httpsqs, das in C mit Tokyo Cabinet geschrieben ist.

Was der Test ergab: 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 Minuten.

Einfacher asynchroner Nachrichtenbus in Go

Was der Test ergab: 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 Minuten.

Das serverless Framework, speziell entwickelt für Event-Streaming-Anwendungen.

Was der Test ergab: Go 1.25.0 installed, project builds, controller test suite passes all 57 specs using real Kubernetes envtest binaries. 8 Minuten.

Eine einfachste In-Memory- und verteilte, speicherunabhängige Nachrichtenwarteschlange für Ihr nebenläufiges Go-Programm

Was der Test ergab: 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 Minuten.

Message-Queue-Bundle für Symfony. RabbitMQ, Amazon SQS, Redis, Service Bus, asynchrone Events, RPC über MQ und vieles mehr.

Was der Test ergab: 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 Minuten.

Schneller und leichtgewichtiger Prozessor für Logs, Metriken und Traces auf Linux, BSD, OSX und Windows

Was der Test ergab: 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 Minuten.

Verteilte Log-Streaming-Engine, von Grund auf entwickelt.

Was der Test ergab: 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 Minuten.

csp ist eine leistungsstarke reaktive Streamverarbeitungsbibliothek, geschrieben in C++ und Python

Was der Test ergab: 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 Minuten.

Asynchrones Python-Framework für ereignisgesteuerte Dienste. Ein schlanker Client für Kafka, RabbitMQ, NATS, Redis und MQTT mit vollem Zugriff auf native...

Was der Test ergab: 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 Minuten.

Graphbasiertes Framework für Datenstrom-Verarbeitung mit ultra-niedriger Latenz

Was der Test ergab: 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 Minuten.

Redis Simple Message Queue

Was der Test ergab: 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 Minuten.

Apache StreamPipes: Eine Self-Service-Toolbox für das industrielle IoT, die es nicht-technischen Benutzern ermöglicht, IoT-Datenströme zu verbinden, zu...

Was der Test ergab: 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 Minuten.

Hochleistungs-Job-Warteschlange für Bun. Standardmäßig SQLite, PostgreSQL-Multi-Broker, wenn Sie skalieren. DLQ, Cron, SQLite-S3-Backups und natives MCP. Kein...

Was der Test ergab: 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 Minuten.

Ein modernes, hochleistungsfähiges Open-Source-Nachrichtenwarteschlangensystem

Was der Test ergab: BlazingMQ broker, CLI tool, and storage tool binaries are built and functional with 212/212 unit tests passing. 75 Minuten.

flink-Lernblog.

Was der Test ergab: 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 Minuten.

Kafka-ähnliches Nachrichten-Streaming in Go. Auf NATS aufgebaut. Einzelne Binärdatei, kein JVM, kein ZooKeeper.

Was der Test ergab: 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 Minuten.

iWF ist eine Workflow-As-Code Microservice-Orchestrierungsplattform, die ein Orchestrierungs-Coding-Framework und einen Service zum Erstellen von resilienten...

Was der Test ergab: 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 Minuten.

Der Open-Source- und unternehmensreife Webhooks-Dienst

Was der Test ergab: 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 Minuten.

Message-Queue-, Job-Queue-, Broadcasting- und WebSockets-Pakete für PHP, Symfony, Laravel, Magento. ENTWICKLUNGS-REPOSITORY - bereitgestellt von Forma-Pro

Was der Test ergab: 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 Minuten.

Kurento WebRTC Media Server

Was der Test ergab: konnte nicht verifiziert werden; das Log zeigt, wo es stehen blieb. 8 Minuten.

Kommunikationsinfrastruktur für das KI-Zeitalter: eine Binärdatei, ein Broker, eine Speicherschicht, beliebiges Protokoll

Was der Test ergab: konnte nicht verifiziert werden; das Log zeigt, wo es stehen blieb. 21 Minuten.

Ereignisstromverarbeitung für Entwickler, um Daten in Bewegung zu sammeln und zu transformieren und so reaktionsfähige datenintensive Anwendungen anzutreiben.

Was der Test ergab: konnte nicht verifiziert werden; das Log zeigt, wo es stehen blieb. 87 Minuten.

Stream Processing and Complex Event Processing Engine

Was der Test ergab: konnte nicht verifiziert werden; das Log zeigt, wo es stehen blieb. 87 Minuten.