Amazon Managed Service untuk Apache Flink (Amazon MSF) sebelumnya dikenal sebagai Amazon Kinesis Data Analytics untuk Apache Flink.
Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
Gunakan konektor Apache Flink dengan Managed Service untuk Apache Flink
Konektor Apache Flink adalah komponen perangkat lunak yang memindahkan data masuk dan keluar dari Amazon Managed Service untuk aplikasi Apache Flink. Konektor adalah integrasi fleksibel yang memungkinkan Anda membaca dari file dan direktori. Konektor terdiri dari modul lengkap untuk berinteraksi dengan layanan Amazon dan sistem pihak ketiga.
Tipe konektor termasuk berikut ini:
Sumber: Berikan data ke aplikasi Anda dari aliran data Kinesis, file, topik Apache Kafka, file, atau sumber data lainnya.
-
Tenggelam: Kirim data dari aplikasi Anda ke aliran data Kinesis, aliran Firehose, topik Apache Kafka, atau tujuan data lainnya.
-
Asynchronous I/O: Menyediakan akses asinkron ke sumber data seperti database untuk memperkaya aliran.
Konektor Apache Flink disimpan di repositori sumbernya sendiri. Versi dan artefak untuk konektor Apache Flink berubah tergantung pada versi Apache Flink yang Anda gunakan, dan apakah Anda menggunakan, Table DataStream, atau SQL API.
Amazon Managed Service untuk Apache Flink mendukung lebih dari 40 sumber dan konektor sink Apache Flink yang sudah dibuat sebelumnya. Tabel berikut memberikan ringkasan konektor paling populer dan versi terkaitnya. Anda juga dapat membuat wastafel khusus menggunakan kerangka kerja Async-sink. Untuk informasi selengkapnya, lihat The Generic Asynchronous Base Sink
Untuk mengakses repositori konektor Apache Flink AWS , lihat. flink-connector-aws
| Konektor | Flink versi 1.15 | Flink versi 1.18 | Flink versi 1.19 | Flink versi 1.20 |
|---|---|---|---|---|
| Aliran Data Kinesis - Sumber - DataStream dan API Tabel | 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 |
| Aliran Data Kinesis - Sink - DataStream dan API Tabel | flink-connector-aws-kinesis-aliran, 1.15.4 | flink-connector-aws-kinesis-aliran, 4.3.0-1.18 | flink-connector-aws-kinesis-aliran, 5.0.0-1.19 | flink-connector-aws-kinesis-aliran, 5.0.0-1.20 |
| Kinesis Data Streams - Sumber/Wastafel - 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-aliran, 5.0.0-1.20 |
| Kafka - DataStream dan Tabel API | 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 dan Tabel API | flink-connector-aws-kinesis-selang api, 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-selang api, 4.3.0-1.18 | flink-sql-connector-aws-firehose, 5.0.0-1.19 | flink-sql-connector-aws-firehose, 5.0.0-1.20 |
| DynamoDB - dan Tabel API DataStream | 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 - DataStream dan Tabel API | - | 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 |
| Layanan Dikelola Amazon untuk 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 dan Tabel 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 |
Untuk mempelajari lebih lanjut tentang konektor di Amazon Managed Service untuk Apache Flink, lihat:
Masalah yang diketahui
Ada masalah open source Apache Flink yang diketahui dengan konektor Apache Kafka di Apache Flink 1.15. Masalah ini diselesaikan di versi Apache Flink yang lebih baru.
Untuk informasi selengkapnya, lihat Masalah yang diketahui.
