Короче, нужен оркестратор который будет знать о прохождении процесса. Ему насрать на отдельные месаджи, он иногда запускает в систему свои технические сообщения. Если они не приходят за нужный таймаут, сорц (евент-стор, очередь и пр) откатываются в последнее зафиксированное положение