Ivan Mushketyk created FLINK-8315: ------------------------------------- Summary: 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)