pyflink 断点设置

您好，请问在从kafka source端select数据，经过处理后insert到kafka sink端，中间的过程如何监控，有没有断点机制可以进行记录？感谢！

回复