Как работает концепция контрольных точек / отказоустойчивости в Apache Beam?

Question

Я работаю над конвейером потоковой передачи лучей apache с производителем Kafka в качестве ввода и потребителем для вывода. Может ли кто-нибудь помочь мне с контрольной точкой в ​​apache-beam