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

Port Kinesis Source to new Source API (FLIP-27)

    XMLWordPrintableJSON

Details

    Description

      We want to port the Kinesis Source to the new Source API (FLIP-27) and deprecate the old FlinkKinesisConsumer

      Attachments

        Issue Links

          blocks

          Sub-task - The sub-task of the issue FLINK-32696 Promote Kinesis connector support to PublicEvolving

          • Major - Major loss of function.
          • Open
          duplicates

          Improvement - An improvement or enhancement to an existing feature or task. FLINK-25729 Replace the deprecated FlinkKinesisConsumer with a Kinesis Consumer based on the AWS SDK for Java 2.x

          • Major - Major loss of function.
          • Resolved
          is related to

          Bug - A problem which impairs or prevents the functions of the product. FLINK-36215 Child shards are getting started with LATEST shard iterator even when parents are not expired

          • Major - Major loss of function.
          • Resolved
          links to

          Web Link GitHub Pull Request #49

          Activity

            People

              liangtl Hong Liang Teoh
              martijnvisser Martijn Visser
              Votes:
              3 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

                Created:
                Updated: