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

StateFun Kinesis ingresses should support configs that are available via FlinkKinesisConsumer's ConsumerConfigConstants

    XMLWordPrintableJSON

Details

    Description

      The Kinesis ingress should support the configs that are available in FlinkKinesisConsumer's ConsumerConfigConstants. Instead, currently, all property keys provided to the Kinesis ingress are assumed to be AWS-client related keys, and therefore have all been appended with the `aws.clientconfigs` string.

      I'd suggest to avoid mixing the ConsumerConfigConstants configs within the properties as well. Having named methods on the KinesisIngressBuilder for those configuration would provide a cleaner solution.

      Attachments

        Issue Links

          Activity

            People

              tzulitai Tzu-Li (Gordon) Tai
              tzulitai Tzu-Li (Gordon) Tai
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: