저장점 사용 중지 관련 FlinkKafkaConsumer 문제 - Managed Service for Apache Flink

기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

저장점 사용 중지 관련 FlinkKafkaConsumer 문제

레거시 FlinkKafkaConsumer를 사용할 때 시스템 스냅샷을 활성화한 경우 애플리케이션이 업데이트, 중지 또는 조정에서 멈출 수 있습니다. 이 문제에 대한 수정은 게시되지 않았으므로 이 문제를 완화하려면 새 KafkaSource로 업그레이드하는 것이 좋습니다.

스냅샷이 활성화된 상태로 FlinkKafkaConsumer를 사용하는 경우 Flink 작업에서 저장점 API로 중지 요청을 처리할 때 ClosedException를 보고하는 런타임 오류가 발생하여 FlinkKafkaConsumer이 실패할 수 있습니다. 이러한 상황에서는 Flink 애플리케이션이 중단되고 실패한 체크포인트로 나타납니다.