FlinkKafkaConsumer 使用 savepoint 停止时出现问题

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

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