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