...
The following table shows the relevant FLIPs that lead to the SinkV2 API as it has been released with Flink 1.19
| FLIP | Note | API Annotation | Released with |
|---|---|---|---|
| FLIP-143: Unified Sink API | Introduction of new Unified Sink API | Experimental | Flink 1.12 |
| FLIP-177: Extend Sink API | Extends Unified Sink API | Experimental | Flink 1.14 |
| FLIP-171: Async Sink | Introduces generic Async Sink API, based on the Unified Sink API | PublicEvolving | Flink 1.15 |
| FLIP-191: Extend unified Sink interface to support small file compaction | Extends Unified Sink API with introduction of SinkV2 | Sink: SinkV2: | Flink 1.15 |
| FLIP-372: Enhance and synchronize Sink API to match the Source API | Changed the Sink V2 API so that it uses mixin interfaces to enhance the extendibility of the API, similar to the Source API. | SinkV2: | Flink 1.19 |
The following table shows the state of migration to SinkV2 for ASF supported and released connectors:
| Status | Connector | Used Sink/SinkV2 since | ||||||||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
 | FileSystem | Flink 1.12
| ||||||||||||||||
| Kafka / Upsert-Kafka | Flink 1.14
| ||||||||||||||||
 | Cassandra |
| ||||||||||||||||
| DynamoDB | AWS Connector v3.0 (via ASync API)
| ||||||||||||||||
| Elasticsearch | Flink 1.15
| ||||||||||||||||
| Firehose | Flink 1.15 (via ASync API)
| ||||||||||||||||
| Kinesis | Flink 1.15 (via ASync API)
| ||||||||||||||||
| MongoDB | MongoDB v1.0 (via ASync API)
| ||||||||||||||||
| Opensearch | Opensearch v1.0 (via ASync API)
| ||||||||||||||||
| RabbitMQ |
| ||||||||||||||||
| Google Cloud PubSub |
| ||||||||||||||||
| Pulsar | Flink 1.15
| ||||||||||||||||
| JDBC | JDBC v3.2.0
| ||||||||||||||||
| HBase |
|
This topic has also been previously discussed on the Dev mailing list in https://lists.apache.org/thread/q62nj89rrz0t5xtggy5n65on95f2rmmx
Public Interfaces
Briefly list any new interfaces that will be introduced as part of this proposal or any existing interfaces that will be removed or changed. The purpose of this section is to concisely call out the public contract that will come along with this feature.
...