Skip to main content

Module event_bus_trait

Module event_bus_trait 

Source

Structs§

LegacyMessageEnvelope
Envelope wrapping a message with legacy partition/offset coordinates. Used by subscribers that need to track exactly which messages they’ve processed.
MessageEnvelope
Envelope wrapping a message with a monotonic sequence number. Preferred over LegacyMessageEnvelope for consumers that need ordering.

Traits§

EventBusTrait

Type Aliases§

ReplayHandler
Handler for replayed events (boxed for object safety)
TopicOffsets
Offsets format: topic -> partition -> offset