[
https://issues.apache.org/jira/browse/FLINK-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16311799#comment-16311799
]
Tzu-Li (Gordon) Tai commented on FLINK-8315:
--------------------------------------------
The connector internally uses the {{AWSCredentialsProvider}}, and sets it up
based on the properties.
The initial intent to not expose any AWS classes on the user API of the
connector was to have better control over API backward compatibilities.
> Use AWSCredentialsProvider to get AWS credentials
> -------------------------------------------------
>
> Key: FLINK-8315
> URL: https://issues.apache.org/jira/browse/FLINK-8315
> Project: Flink
> Issue Type: New Feature
> Components: Kinesis Connector
> Reporter: Ivan Mushketyk
> Priority: Minor
>
> Instead of providing credentials like:
> {code:java}
> Properties consumerConfig = new Properties();
> consumerConfig.put(ConsumerConfigConstants.AWS_REGION, "us-east-1");
> consumerConfig.put(ConsumerConfigConstants.AWS_ACCESS_KEY_ID, "...");
> consumerConfig.put(ConsumerConfigConstants.AWS_SECRET_ACCESS_KEY,
> "...");
> consumerConfig.put(ConsumerConfigConstants.STREAM_INITIAL_POSITION,
> "TRIM_HORIZON");
> {code}
> Kinesis connector could use the AWSCredentialsProvider interface.
> I can contribute it myself, but I wonder if this feature makes sense to you.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
