title: How do concept of checkpointing/Fault tolerance work work in apache beam?
body: <p>I am working on the apache beam streaming pipeline with Kafka producer as input and consumer for the output. Can anyone help me out with checkpoint in apache-beam</p>