Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-24438 Port Kinesis Source to new Source API (FLIP-27)
  3. FLINK-31990

Use Flink Configuration to specify KDS Source configuration object

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Closed
    • Major
    • Resolution: Done
    • None
    • None
    • None

    Description

      What

      Use the Flink Configuration object to standardise the method of specifying configurations for the KDS source. 

       

      Also include validations:

      • Check that region in config matches ARN. ARN should take priority.

       

      Why

      We want to standardise error messages + source serialization methods implemented by Flink on the Flink Configuration objects.

       

      Attachments

        Issue Links

          Activity

            People

              liangtl Hong Liang Teoh
              liangtl Hong Liang Teoh
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: