v0.2.0 · World

processor-service

A long-lived read-process-write service.

Consumes, transforms, and produces from the one instance. Combined with transaction.send-offsets, this is the exactly-once pattern: the offsets consumed and the records produced commit atomically, so a crash mid-batch replays cleanly instead of double-writing.