Broker Engine
The core streaming broker: request pipelines, write-ahead logs, coordinators, and consensus via krabka-broker and krabka-log.
The krabka-broker repository contains the primary broker binary and supporting crate subsystems:
| Crate | Purpose & Subsystem |
|---|---|
| krabka-broker | Request handlers, coordinators, partition replication, quotas, server binary |
| krabka-raft | KRaft consensus engine implementing KIP-595 wire RPC protocol |
| krabka-kraft-core | Shared KRaft record types and quorum state machine |
| krabka-log | On-disk write-ahead log: segments, index files, compaction, retention |
| krabka-remote-storage | Tiered-storage reader and cloud object storage offloader |
| krabka-remote-storage-topic | The __remote_log_metadata topic-backed RLMM |
| krabka-authz | Authorizer traits, ACL evaluations, and OPA client |
| krabka-audit | Security audit events, OCSF serialization, and verify CLI |
| krabka-format | Formats fresh log directory: meta.properties.json and VotersRecord |
| krabka-telemetry | OTLP pipeline, Prometheus metrics, and pprof debug endpoints |