Struct KafkaBus 

pub struct KafkaBus { /* private fields */ }

Kafka/Redpanda bus.

Implementations

impl KafkaBus

pub fn provision( broker: &str, manifest: &BridgeManifest, ) -> Result<Self, BusError>

Connect to broker (host:port) and provision topics per the manifest.

Trait Implementations

impl EventBus for KafkaBus

fn set_control_key(&self, key: [u8; 32]) -> Result<(), BusError>

Configure the signer-derived key used for authenticated local controls.

fn publish( &self, topic: &str, key: &str, value: &Value, ) -> Result<PublishAck, BusError>

Publish value onto topic, partitioned by key. Returns the ack.

fn publish_idempotent( &self, topic: &str, key: &str, value: &Value, event_uid: &str, ) -> Result<PublishAck, BusError>

Publish a stable event UID. Backends with native or local deduplication override this method; the default preserves compatibility while the UID remains embedded in the event payload for downstream deduplication.

fn find_event_by_uid( &self, topic: &str, key: &str, event_uid: &str, ) -> Result<Option<PublishAck>, BusError>

Locate an already committed event by stable UID during crash recovery.

fn fetch( &self, topic: &str, partition: u32, offset: u64, max: usize, ) -> Result<Vec<StoredEvent>, BusError>

Read up to max events from topic/partition starting at offset (ordered replay).

fn partitions(&self, topic: &str) -> Result<u32, BusError>

Number of partitions configured for topic.

fn topics(&self) -> Vec<String>

Topics currently provisioned.

fn maintenance(&self, _now_ms: u64) -> Result<u64, BusError>

Run backend maintenance such as hot-retention expiry. Managed brokers may return zero when retention is enforced natively.