The Reaqtor framework supports reliability by persistently storing the state via checkpointing. These checkpoints record where in each observable stream you have reached, and the operator state at that point.