flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tzu-Li (Gordon) Tai (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-8315) Use AWSCredentialsProvider to get AWS credentials
Date Thu, 04 Jan 2018 18:20:01 GMT

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

Mime
View raw message