The core logic for your Kafka processor, part of kafka-json-processor project.
Custom Kafka JSON processor generator, part of kafka-json-processor project.
The base for a custom code generator for kjp-generator, part of kafka-json-processor project.
Configuration and route discovery for rust-camel
Asynchronous Bitcoin block ingestion pipeline with built-in reorg handling, backpressure, and observability
Diagnostic TUI for monitoring Caryatid message bus activity
An asynchronous message bridging library connecting Kafka, MQTT, AMQP, NATS, MongoDB, HTTP, and more.
timeseries library
A declarative, config-driven data pipeline with pluggable source and sink connectors
High-performance, schema-agnostic, backend-agnostic event bus
High-performance, schema-agnostic, backend-agnostic event bus
A Kafka-like message broker in Rust