Amazon Managed Service für Apache Flink war zuvor als Amazon Kinesis Data Analytics für Apache Flink bekannt.
Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.
Verwenden Sie Apache Flink-Konnektoren mit Managed Service für Apache Flink
Apache Flink-Konnektoren sind Softwarekomponenten, die Daten in und aus einer Amazon Managed Service für Apache Flink-Anwendung übertragen. Konnektoren sind flexible Integrationen, mit denen Sie aus Dateien und Verzeichnissen lesen können. Konnektoren bestehen aus kompletten Modulen für die Interaktion mit Amazon-Services und Systemen von Drittanbietern.
Zu den Konnektoren gehören die folgenden:
Quellen: Stellen Sie Ihrer Anwendung Daten aus einem Kinesis-Datenstream, einer Datei, einem Apache Kafka-Thema, einer Datei oder anderen Datenquellen bereit.
-
Senken: Senden Sie Daten aus Ihrer Anwendung an einen Kinesis-Datenstream, Firehose-Stream, Apache Kafka-Thema oder andere Datenziele.
-
Asynchrone I/O: Ermöglicht asynchronen Zugriff auf eine Datenquelle, z. B. eine Datenbank, um Streams anzureichern.
Apache Flink-Konnektoren werden in ihren eigenen Quell-Repositorys gespeichert. Die Version und das Artefakt für Apache Flink-Konnektoren ändern sich je nachdem, welche Apache Flink-Version Sie verwenden und ob Sie die Table- oder DataStream SQL-API verwenden.
Amazon Managed Service für Apache Flink unterstützt über 40 vorgefertigte Apache Flink-Quell- und Senken-Konnektoren. Die folgende Tabelle enthält eine Zusammenfassung der beliebtesten Konnektoren und der zugehörigen Versionen. Sie können auch benutzerdefinierte Senken mithilfe des Async-Sink-Frameworks erstellen. Weitere Informationen finden Sie unter The Generic Asynchronous Base Sink
Informationen zum Zugriff auf das Repository für Apache AWS Flink-Konnektoren finden Sie unter. flink-connector-aws
| Konnektor | Flink Version 1.15 | Flink versie 1.18 | Flink-Versionen 1.19 | Flink-Versionen 1.20 |
|---|---|---|---|---|
| Kinesis Data Stream — Quell DataStream - und Tabellen-API | flink-connector-kinesis, 1.15.4 | flink-connector-kinesis, 4,3,0-1,18 | flink-connector-kinesis, 5,0,0-1,19 | flink-connector-kinesis, 5,0,0-1,20 |
| Kinesis Data Stream — Sink DataStream - und Tabellen-API | flink-connector-aws-kinesis-Streams, 1.15.4 | flink-connector-aws-kinesis-Streams, 4.3.0-1.18 | flink-connector-aws-kinesis-Streams, 5.0.0-1.19 | flink-connector-aws-kinesis-Streams, 5.0.0-1.20 |
| Kinesis Data Streams — Quelle/Senke — SQL | flink-sql-connector-kinesis, 1.15.4 | flink-sql-connector-kinesis, 4,3,0-1,18 | flink-sql-connector-kinesis, 5,0,0-1,19 | flink-sql-connector-kinesis-Streams, 5.0.0-1.20 |
| Kafka — und Tabellen-API DataStream | flink-connector-kafka, 1.15.4 | flink-connector-kafka, 3.2.0-1.18 | flink-connector-kafka, 3,3,0-1,19 | flink-connector-kafka, 3,3,0-1,20 |
| Kafka - SQL | flink-sql-connector-kafka, 1.15.4 | flink-sql-connector-kafka, 3.2.0-1.18 | flink-sql-connector-kafka, 3,3,0-1,19 | flink-sql-connector-kafka, 3,3,0-1,20 |
| Firehose DataStream - und Tabellen-API | flink-connector-aws-kinesis-Firehose, 1.15.4 | flink-connector-aws-firehose, 4.3.0-1.18 | flink-connector-aws-firehose, 5,0,0-1,19 | flink-connector-aws-firehose, 5,0,0-1,20 |
| Firehose - SQL | flink-sql-connector-aws-Kinesis-Firehose, 1.15.4 | flink-sql-connector-aws-Feuerwehrschlauch, 4.3.0-1.18 | flink-sql-connector-aws-Feuerwehrschlauch, 5.0.0-1.19 | flink-sql-connector-aws-Feuerwehrschlauch, 5.0.0-1.20 |
| DynamoDB - DataStream und Tabellen-API | flink-connector-dynamodb, 3.0.0-1.15 | flink-connector-dynamodb, 4,3,0-1,18 | flink-connector-dynamodb, 5,0,0-1,19 | flink-connector-dynamodb, 5,0,0-1,20 |
| DynamoDB - SQL | flink-sql-connector-dynamodb, 3.0.0-1.15 | flink-sql-connector-dynamodb, 4,3,0-1,18 | flink-sql-connector-dynamodb, 5,0,0-1,19 | flink-sql-connector-dynamodb, 5,0,0-1,20 |
| OpenSearch - und Tabellen-API DataStream | - | flink-connector-opensearch, 1.2.0-1.18 | flink-connector-opensearch, 1,2.0-1,19 | flink-connector-opensearch, 1,2.0-1,19 |
| OpenSearch - SQL | - | flink-sql-connector-opensearch, 1.2.0-1.18 | flink-sql-connector-opensearch, 1,2.0-1,19 | flink-sql-connector-opensearch, 1,2.0-1,19 |
| Amazon Managed Service für Prometheus DataStream | - | flink-sql-connector-opensearch, 1.2.0-1.18 | flink-connector-prometheus, 1.0.0-1,19 | flink-connector-prometheus, 1.0.0-1,20 |
| Amazon SQS DataStream und Tabellen-API | - | flink-sql-connector-opensearch, 1.2.0-1.18 | flink-connector-sqs, 5,0,0-1,19 | flink-connector-sqs, 5,0,0-1,20 |
Weitere Informationen zu Konnektoren in Amazon Managed Service für Apache Flink finden Sie unter:
Bekannte Probleme
Es gibt ein bekanntes Open-Source-Apache Flink-Problem mit dem Apache Kafka-Konnektor in Apache Flink 1.15. Dieses Problem wurde in späteren Versionen von Apache Flink behoben.
Weitere Informationen finden Sie unter Bekannte Probleme.
