1 2 3 4 5 6 7 8
/// Kafka bus backend (stub — full implementation in Phase 8 cluster). pub struct KafkaBus; impl KafkaBus { pub fn new(_brokers: &[String], _group_id: &str) -> Self { Self } }