The Maelstrom broker. This process coordinates between clients and workers.
Async RPC over AMQP, DDS, MQTT, and Redis. Transport-agnostic — switch brokers via feature flags, not code.
An MQTT client that runs command line commands based on a configuration file or arbitrary input.
Unofficial Rust implementation of Apache RocketMQ
High-performance AI coding agent CLI - Rust port of Pi Agent
In-process log with Kafka-like semantics: topics, partitions, offset-based reads, replay, retention.
AXON — the formal cognitive language: a deterministic, proof-carrying AI runtime. Native Rust lexer/parser/type-checker/IR generator (re-exported from axon-frontend) plus the runtime: typed channels (π-calculus mobility, capability extrusion), algebraic effects via Free Monad CPS handlers, lease kernel + reconcile loop, the Epistemic Security Kernel, Trust Types, Proof-Carrying Code (independently verifiable proof objects), and the closed-catalog extension mechanism. Crate publishes as `axon-lang`; library import is `use axon::*` so existing call sites keep working unchanged.
Auto-generated Rust client for the Brokkr broker API
The broker forwards requests upstream (towards responders) and forwards responses downstream (towards requestors)
Apache Kafka compatible broker with S3, PostgreSQL, Apache Iceberg and Delta Lake
Tansu Kafka API compatible broker
Fetch or produce (with validation when backed by a schema) messages to a topic