Amazon Managed Service for Apache Flink는 이전에 Amazon Kinesis Data Analytics for Apache Flink로 알려졌습니다.
기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.
커넥터를 사용하여 Apache Flink용 관리 서비스에서 데이터를 이동할 수 있습니다. DataStream API
Apache Flink용 Amazon 관리형 서비스에서 커넥터는 Apache DataStream API Flink용 관리형 서비스 애플리케이션에서 데이터를 내보내고 받는 소프트웨어 구성 요소입니다. 커넥터는 파일과 디렉터리에서 읽을 수 있는 유연한 통합입니다. 커넥터는 Amazon 서비스 및 제3자 시스템과 상호 작용하기 위한 완전한 모듈로 구성됩니다.
커넥터 유형은 다음을 포함합니다.
Apache Flink용 관리형 서비스에 스트리밍 데이터 소스 추가: Kinesis 데이터 스트림, 파일 또는 기타 데이터 소스에서 애플리케이션에 데이터를 제공합니다.
Apache Flink용 관리형 서비스에서 싱크를 사용하여 데이터 쓰기: 애플리케이션의 데이터를 Kinesis 데이터 스트림, Firehose 스트림 또는 기타 데이터 대상으로 전송합니다.
Apache Flink용 매니지드 서비스의 비동기 I/O 사용: 스트림 이벤트를 강화하기 위해 데이터 소스(예: 데이터베이스)에 대한 비동기 액세스를 제공합니다.
사용 가능한 커넥터
Apache Flink 프레임워크에는 다양한 소스의 데이터에 액세스하기 위한 커넥터가 포함되어 있습니다. Apache Flink 프레임워크에서 사용할 수 있는 커넥터에 대한 자세한 내용을 알아보려면 Apache Flink 설명서
주의
Flink 1.6, 1.8, 1.11 또는 1.13에서 실행되는 애플리케이션이 중동 (UAE), 아시아 태평양 (하이데라바드), 이스라엘 (텔아비브), 유럽 (취리히), 중동 (), 아시아 태평양 (멜버른) 또는 아시아 태평양 (자카르타UAE) 지역에서 실행하려는 경우 업데이트된 커넥터로 애플리케이션 아카이브를 재구축하거나 Flink 1.18로 업그레이드해야 할 수 있습니다.
Apache Flink 커넥터는 자체 오픈 소스 리포지토리에 저장됩니다. 버전 1.18 이상으로 업그레이드하는 경우 종속성을 업데이트해야 합니다. Apache Flink AWS 커넥터의 저장소에 액세스하려면 을 참조하십시오. flink-connector-aws
다음은 권장 가이드라인입니다.
커넥터 업그레이드 | |||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
| Flink 버전 | 커넥터 사용 | 해결 방법 | |||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| 1.15 | EFO |
Apache Flink용 Amazon Managed Service 버전 1.15로 업그레이드할 때는 최신 커넥터를 사용하고 있는지 확인하십시오. EFO 버전 1.15.3 이상이어야 합니다. 자세한 내용은 다음을 참조하세요. |
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| 1.15 | 아마존 데이터 파이어호스 싱크 |
Apache Flink용 Amazon 매니지드 서비스 버전 1.15로 업그레이드할 때는 최신 Amazon Data Firehose Sink를 사용하고 있는지 확인하십시오. |
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| 1.15 | 카프카 커넥터 |
Apache Flink용 Amazon 매니지드 서비스 버전 1.15로 업그레이드할 때는 최신 Kafka 커넥터를 사용하고 있는지 확인하십시오. APIs 아파치 플링크는 더 이상 사용되지 않으며. FlinkKafkaConsumerFlinkKafkaProducer |
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| 1.6 - 1.13 | Firehose |
애플리케이션은 최신 지역을 인식하지 못하는 오래된 버전의 Firehose 커넥터를 사용합니다. AWS Firehose 커넥터 버전 2.1.0으로 애플리케이션 아카이브를 다시 구축하세요. |
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| 1.8 | Kinesis |
애플리케이션은 최신 지역을 인식하지 못하는 오래된 버전의 Flink Kinesis 커넥터를 사용합니다. AWS Flink Kinesis 커넥터 버전 1.6.1을 사용하여 애플리케이션 아카이브를 다시 구축하세요. https://github.com/awslabs/amazon-kinesis-connector-flink/tree/1.6.1 |
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| 1.11 | Kinesis |
애플리케이션은 최신 지역을 인식하지 못하는 오래된 버전의 Flink Kinesis 커넥터를 사용합니다. AWS Flink Kinesis 커넥터 버전 2.4.1을 사용하여 애플리케이션 아카이브를 다시 구축하세요. https://github.com/awslabs/amazon-kinesis-connector-flink/tree/2.4.1 |
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| 1.6 및 1.13 | Kinesis |
애플리케이션은 최신 지역을 인식하지 못하는 오래된 버전의 Flink Kinesis 커넥터를 사용합니다. AWS 안타깝게도 Flink는 더 이상 1.6/1.13 커넥터에 대한 패치나 버그 수정을 릴리스하지 않습니다. Flink 1.15로 애플리케이션 아카이브를 다시 구축하여 Flink 1.15로 업데이트하는 것이 좋습니다. |
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
