Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-3211 Add AWS Kinesis streaming connector
  3. FLINK-3923

Unify configuration conventions of the Kinesis producer to the same as the consumer

    XMLWordPrintableJSON

Details

    Description

      Currently, the Kinesis consumer and producer are configured differently.

      The producer expects a list of arguments for the access key, secret, region, stream. The consumer is accepting properties (similar to the Kafka connector).

      The objective of this issue is to change the producer so that it is also using a properties-based configuration (including an input validation step)

      Attachments

        Issue Links

          Activity

            People

              aozturk Abdullah Ozturk
              rmetzger Robert Metzger
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: