

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

# Managed Service for Apache Flink에서 DataStream API를 사용한 데이터 이동 커넥터 사용
<a name="how-connectors"></a>

Amazon Managed Service for Apache Flink DataStream API에서 *커넥터*는 Managed Service for Apache Flink 애플리케이션에서 데이터를 내보내고 받는 소프트웨어 구성 요소입니다. 커넥터는 파일과 디렉터리에서 읽을 수 있는 유연한 통합 구성 요소입니다. 커넥터는 Amazon 서비스 및 제3자 시스템과 상호 작용하기 위한 완전한 모듈로 구성됩니다.

커넥터 유형은 다음을 포함합니다.
+ [스트리밍 데이터 소스 추가](how-sources.md): Kinesis 데이터 스트림, 파일 또는 기타 데이터 소스에서 애플리케이션에 데이터를 제공합니다.
+ [싱크를 사용하여 데이터 쓰기](how-sinks.md): 애플리케이션에서 Kinesis 데이터 스트림, Firehose 스트림 또는 기타 데이터 대상으로 데이터를 전송합니다.
+ [비동기식 I/O 사용](how-async.md): 스트림 이벤트를 강화하기 위해 데이터 소스(예: 데이터베이스)에 대한 비동기 액세스를 제공합니다.

## 사용 가능한 커넥터
<a name="how-connectors-list"></a>

Apache Flink 프레임워크에는 다양한 소스의 데이터에 액세스하기 위한 커넥터가 포함되어 있습니다. Apache Flink 프레임워크에서 사용할 수 있는 커넥터에 대한 자세한 내용을 알아보려면 [Apache Flink 설명서](https://nightlies.apache.org/flink/flink-docs-release-1.15/)의 [커넥터](https://nightlies.apache.org/flink/flink-docs-release-1.15/dev/connectors/)를 참조하세요.

**주의**  
Flink 1.6, 1.8, 1.11 또는 1.13에서 실행되는 애플리케이션을 중동(UAE), 아시아 태평양(하이데라바드), 이스라엘(텔아비브), 유럽(취리히), 아시아 태평양(멜버른) 또는 아시아 태평양(자카르타) 리전에서 실행하려는 경우 업데이트된 커넥터로 애플리케이션 아카이브를 재구축하거나 Flink 1.18로 업그레이드해야 할 수 있습니다.  
Apache Flink 커넥터는 각 커넥터별로 분리된 오픈 소스 리포지토리에 저장됩니다. 버전 1.18 이상으로 업그레이드하는 경우 종속 항목을 업데이트해야 합니다. Apache Flink AWS 커넥터의 리포지토리에 액세스하려면 [flink-connector-aws](https://github.com/apache/flink-connector-aws)를 참조하세요.  
이전 Kinesis 소스 `org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer`는 지원이 중단되었으며 향후 Flink 릴리스에서 제거될 수 있습니다. 대신 [Kinesis 소스](https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/connectors/datastream/kinesis/#kinesis-streams-source)를 사용합니다.  
`FlinkKinesisConsumer` 및 `KinesisStreamsSource` 사이에는 상태 호환성이 없습니다. 자세한 내용은 Apache Flink 설명서의 [Kinesis Streams 소스로 기존 작업 마이그레이션](https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/connectors/datastream/kinesis/#migrating-existing-jobs-to-new-kinesis-streams-source-from-kinesis-consumer)을 참조하세요.  
 다음은 권장 가이드라인입니다.  


**커넥터 업그레이드**  

| Flink 버전 | 커넥터 사용 | 해결 방법 | 
| --- | --- | --- | 
| 1.19, 1.20 | Kinesis 소스 |  Managed Service for Apache Flink 1.19 및 1.20으로 업그레이드할 때는 최신 Kinesis Data Streams 소스 커넥터를 사용하고 있는지 확인합니다. 5.0.0 이상 버전이어야 합니다. 자세한 내용은 [Amazon Kinesis Data Streams 커넥터](https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/datastream/kinesis/)를 참조하세요.  | 
| 1.19, 1.20 | Kinesis 싱크 |  Managed Service for Apache Flink 1.19 및 1.20으로 업그레이드할 때는 최신 Kinesis Data Streams 싱크 커넥터를 사용하고 있는지 확인합니다. 5.0.0 이상 버전이어야 합니다. 자세한 내용은 [Kinesis Streams 싱크](https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/connectors/datastream/kinesis/#kinesis-streams-sink)를 참조하세요.  | 
| 1.19, 1.20 | DynamoDB 스트림 소스 |  Managed Service for Apache Flink 1.19 및 1.20으로 업그레이드할 때는 최신 DynamoDB 스트림 소스 커넥터를 사용하고 있는지 확인합니다. 5.0.0 이상 버전이어야 합니다. 자세한 내용은 [Amazon DynamoDB 커넥터](https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/datastream/dynamodb/)를 참조하세요.  | 
| 1.19, 1.20 | DynamoDB 싱크 | Managed Service for Apache Flink 1.19 및 1.20으로 업그레이드할 때는 최신 DynamoDB 싱크 커넥터를 사용하고 있는지 확인합니다. 5.0.0 이상 버전이어야 합니다. 자세한 내용은 [Amazon DynamoDB 커넥터](https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/datastream/dynamodb/)를 참조하세요. | 
| 1.19, 1.20 | Amazon SQS 싱크 |  Managed Service for Apache Flink 버전 1.19 및 1.20으로 업그레이드할 때는 최신 Amazon SQS 싱크 커넥터를 사용하고 있는지 확인합니다. 5.0.0 이상 버전이어야 합니다. 자세한 내용은 [Amazon SQS 싱크](https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/datastream/sqs/)를 참조하세요.  | 
| 1.19, 1.20 | Amazon Managed Service for Prometheus 싱크 |  Managed Service for Apache Flink 버전 1.19 및 1.20으로 업그레이드할 때는 최신 Amazon Managed Service for Prometheus 싱크 커넥터를 사용하고 있는지 확인합니다. 1.0.0 이상 버전이어야 합니다. 자세한 내용은 [Prometheus 싱크](https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/datastream/prometheus/)를 참조하세요.  | 