Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-25610

[FLIP-171] Kinesis Firehose implementation of Async Sink Table API

    XMLWordPrintableJSON

Details

    Description

      Motivation

      User stories:
      As a Flink user, I’d like to use the Table API for the new Kinesis Firehose async sink.

      Scope:

      • Add a new module for flink-connector-kinesis-data-firehose-table.
      • Implement a new KinesisFirehoseDynamicTableSink that uses KinesisDataFirehoseSink Async Implementation and implements AsyncDynamicTableSink.
      • The implementation introduces Async Sink configurations as optional options in the table definition, with default values derived from the KinesisDataFirehose default values.
      • Unit/Integration testing. modify KinesisTableAPI tests for the new implementation, add unit tests for AsyncDynamicTableSink and KinesisDynamicTableSink and KinesisDynamicTableSinkFactory.
      • Java / code-level docs.
      • Add documentations for Table Api connector for Kinesis data firehose.

      References

      More details to be found https://cwiki.apache.org/confluence/display/FLINK/FLIP-171%3A+Async+Sink

      Attachments

        Issue Links

          Activity

            People

              chalixar Ahmed Hamdy
              chalixar Ahmed Hamdy
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: