FlinkKafkaConsumer 與保存點停止問題 - Managed Service for Apache Flink

Amazon Managed Service for Apache Flink 之前稱為 Amazon Kinesis Data Analytics for Apache Flink。

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

FlinkKafkaConsumer 與保存點停止問題

使用舊版時，如 FlinkKafkaConsumer 果您啟用了系統快照，您的應用程序可能會卡在更新，停止或擴展中。此問題沒有已發佈的修正程式可用，因此建議您升級KafkaSource至新版本以減輕此問題。

如果您正在啟用快照的情況下使用 FlinkKafkaConsumer，Flink 作業可能會使用儲存點 API 請求處理停止，FlinkKafkaConsumer 可能會失敗並報告執行期錯誤 ClosedException。在這些情況下，Flink 應用程式會卡住，並顯示為失敗的檢查點。