Usa i connettori per spostare i dati in Managed Service for Apache Flink con DataStream API - Servizio gestito per Apache Flink
Connettori disponibili

Il servizio gestito da Amazon per Apache Flink era precedentemente noto come Analisi dei dati Amazon Kinesis per Apache Flink.

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Usa i connettori per spostare i dati in Managed Service for Apache Flink con DataStream API

In Amazon Managed Service for Apache Flink DataStream API, i connettori sono componenti software che spostano i dati da e verso un'applicazione Managed Service for Apache Flink. I connettori sono integrazioni flessibili che consentono di leggere da file e directory. I connettori sono costituiti da moduli completi per l'interazione con i servizi Amazon e i sistemi di terze parti.

I tipi di connettori comprendono:

Connettori disponibili

Il framework Apache Flink contiene connettori per l'accesso ai dati da vari tipi di origini. Per informazioni sui connettori disponibili nel framework Apache Flink, consulta Connettori nella documentazione di Apache Flink.

avvertimento

Se disponi di applicazioni in esecuzione su Flink 1.6, 1.8, 1.11 o 1.13 e desideri eseguirle nelle regioni del Medio Oriente (UAE), Asia Pacifico (Hyderabad), Israele (Tel Aviv), Europa (Zurigo), Medio Oriente (), Asia Pacifico (MelbourneUAE) o Asia Pacifico (Giacarta), potrebbe essere necessario ricostruire l'archivio delle applicazioni con un connettore aggiornato o eseguire l'aggiornamento a Flink 1.18.

I connettori Apache Flink sono archiviati nei propri archivi open source. Se stai eseguendo l'aggiornamento alla versione 1.18 o successiva, devi aggiornare le tue dipendenze. Per accedere al repository per i connettori Apache Flink, vedi. AWS flink-connector-aws

Di seguito sono riportate le linee guida consigliate:

Aggiornamenti dei connettori
Versione di Flink Connettore usato Risoluzione
1.15 EFO

Quando esegui l'aggiornamento ad Amazon Managed Service for Apache Flink versione 1.15, assicurati di utilizzare il connettore più recente. EFO Deve essere una qualsiasi versione 1.15.3 o successiva. Per ulteriori informazioni, consultare:

FLINK-29324.
1.15 Lavello Amazon Data Firehose

Quando esegui l'aggiornamento ad Amazon Managed Service for Apache Flink versione 1.15, assicurati di utilizzare l'Amazon Data Firehose Sink più recente.

Lavello Amazon Data Firehose
1.15 Connettori Kafka

Quando esegui l'aggiornamento ad Amazon Managed Service for Apache Flink versione 1.15, assicurati di utilizzare il connettore Kafka più recente. APIs Apache Flink è obsoleto e. FlinkKafkaConsumerFlinkKafkaProducer Questi APIs per il Kafka sink non possono impegnarsi con Kafka for Flink 1.15. Assicurati di utilizzare e. KafkaSourceKafkaSink
1.6 - 1.13 Firehose

L'applicazione dipende da una versione obsoleta del connettore Firehose che non riconosce le regioni più recenti. AWS Ricostruisci l'archivio delle applicazioni con il connettore Firehose versione 2.1.0.

v2.1.0
1.8 Kinesis

L'applicazione dipende da una versione obsoleta del connettore Flink Kinesis che non riconosce le regioni più recenti. AWS Ricostruisci l'archivio dell'applicazione con il connettore Flink Kinesis versione 1.6.1.

https://github.com/awslabs/amazon-kinesis-connector-flink/tree/1.6.1
1.11 Kinesis

L'applicazione dipende da una versione obsoleta del connettore Flink Kinesis che non riconosce le regioni più recenti. AWS Ricostruisci l'archivio dell'applicazione con il connettore Flink Kinesis versione 2.4.1.

https://github.com/awslabs/amazon-kinesis-connector-flink/tree/2.4.1
1.6 e 1.13 Kinesis

L'applicazione dipende da una versione obsoleta del connettore Flink Kinesis che non riconosce le regioni più recenti. AWS Sfortunatamente, Flink non rilascia più patch o correzioni di bug per i connettori 1.6/1.13. Ti consigliamo di eseguire l'aggiornamento a Flink 1.15 ricostruendo l'archivio dell'applicazione con Flink 1.15.