Hello All, I am having a scenario, where we have multiple sources and topics and we wanted to add our custom checkpointing logic to maintain and deal with failures if occurred. Does Flink allow me to add custom checkpointing logic over multiple kafka sources ? Please suggest article/github if any. Many Thanks in advance!

Thanks David, useful link!