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)
