Struct OutboxForwarder 

pub struct OutboxForwarder { /* private fields */ }

Forwarder that drains the transactional outbox and publishes records.

Typical flow:
1. Application writes domain rows and enqueues an outbox event in the same DB transaction.
2. After commit, `OutboxForwarder` publishes the event to Kafka/Redpanda.
3. Once the broker acknowledges the write, the forwarder marks the outbox row as published.

This mirrors the transactional outbox pattern (see microservices.io) and provides
at-least-once delivery. When configured with a Kafka `transactional.id`, the forwarder
wraps each batch in a producer transaction for effectively-exactly-once semantics.

Implementations

impl OutboxForwarder

pub fn new(storage: Arc<Storage>, config: BusConfig) -> Result<Self>

pub fn with_exporters(self, exporters: Vec<Arc<dyn OutboxExporter>>) -> Self

pub async fn run(self: Arc<Self>) -> Result<()>

Runs the forwarder loop until shutdown.