crabka-broker 0.3.6

Single-node Apache Kafka-compatible broker (MVP)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

//! KIP-1071 Streams rebalance-protocol subsystem. Broker-side task assignment
//! for Kafka Streams groups: topology ingestion, internal-topic management,
//! active/standby/warmup task assignment, and the heartbeat epoch dance.
//!
//! Mirrors the KIP-932 share-group subsystem (`super::share`) in shape and the
//! KIP-848 next-gen consumer coordinator (`super`) in reconciliation mechanics,
//! but assigns *tasks* `(subtopology, partition)` across active/standby/warmup
//! roles rather than partitions.
pub mod actor;
pub mod assignor;
pub mod config;
pub(crate) mod migration;
pub mod persistence;
pub mod state;
pub mod topology;