FlinkafkaConsumer 使用保存点停止时出现问题

在使用旧版 FlinkafkaConsumer 时，如果你启用了系统快照，你的应用程序可能会陷入更新、停止或缩放的困境。没有针对此问题的已发布修复程序，因此我们建议您升级到新的 KafkaSource 以缓解此问题。

如果您在FlinkKafkaConsumer启用快照的情况下使用的，则当 Flink 任务在处理 savepoint API 请求时停止时，FlinkKafkaConsumer可能会失败，并报告运行时系统错误。ClosedException在这种情况下，Flink 应用程序会卡住，表现为失败的检查点。