Micro-batches, a checkpoint, and a watermark dropping state.
Step 1 of 5
Watch the canvas:offset rangesmicro-batch jobcheckpointstate storewatermarktrigger modeLive simulation
Each trigger turns new offsets into an ordinary batch job; the checkpoint makes restart safe and the watermark is what stops state from growing forever.