At-least-once Stream Delivery

Offsets commit after handler success; a crash before commit replays the event, and the HasActiveEntry guard turns the duplicate into a logged no-op

At-least-once Stream Delivery Offsets commit after handler success; a crash before commit replays the event, and the HasActiveEntry guard turns the duplicate into a logged no-op publish event deliver offset N CompleteActivity applied silo crash: no commit redeliver offset N CompleteActivity stale: logged no-op commit offset N First delivery Replay after crash Producer · WorkflowInstance · Sequence participant Producer WorkflowInstance Kafka · topic offsets · Sequence participant Kafka topic offsets Handler · stream consumer · Sequence participant Handler stream consumer Workflow · HasActiveEntry · Sequence participant Workflow HasActiveEntry Legend request return crash redelivery message

Sequence diagram • Built with Archify • Create yours ↗ • Hover to trace • R route • Click to focus • +/− zoom • M radar • T theme • E export