Tzu-Li (Gordon) Tai created FLINK-22529: -------------------------------------------
Summary: StateFun Kinesis ingresses should support configs that are available via FlinkKinesisConsumer's ConsumerConfigConstants Key: FLINK-22529 URL: https://issues.apache.org/jira/browse/FLINK-22529 Project: Flink Issue Type: Improvement Components: Stateful Functions Reporter: Tzu-Li (Gordon) Tai 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. -- This message was sent by Atlassian Jira (v8.3.4#803005)