我有一个flink应用程序，它是按照事件源范例实现的。事件和命令都存储在几个Kafka主题中。
应用程序有两种启动模式：恢复和生产。首先，恢复模式用于从事件主题恢复应用程序状态（保存点）。在此模式下，根本不读取命令。处理完所有事件主题后，将手动触发保存点（从命令行）并停止应用程序。然后，在生产模式下开始Yarn加工。在这种模式下，应用程序处理事件和命令。
我更喜欢用程序执行这个过程。为此，出现了几个问题。。。应用程序本身如何：
是否检测到Kafka的资料已经完全阅读？
以编程方式触发保存点？
以编程方式停止和启动？
谢谢您！