[ 
https://issues.apache.org/jira/browse/FLINK-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16308225#comment-16308225
 ] 

Aljoscha Krettek commented on FLINK-8315:
-----------------------------------------

I think this makes sense, but I'm not too familiar with the Kinesis connector. 
[~tzulitai] and [~phoenixjiangnan], what do you think about this?

> 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)

Reply via email to