在StackOverflow(link)的其他地方,对AWS S3的访问是这样完成的:
AmazonS3 amazonS3 = AmazonS3Client.builder()
.withRegion("us-east-1")
.withCredentials(new AWSStaticCredentialsProvider(creds))
.build();
我想将此模式用于AmazonKinesisAsyncClientBuilder
,但没有任何方法可以设置区域或凭据。
即这无法编译:
AmazonKinesisAsyncClientBuilder
.withRegion("eu-west-1")
.withCredentials(new AWSStaticCredentialsProvider(creds))
.build();
我从自定义文件中引入了信用卡(在AWS中是正常的); AmazonKinesisAsyncClientBuilder
只能使用默认值吗?
使用AWS SDK for Java 2.5.1
计划通过AlpakkaKinesis阅读Kinesis,但这可能不相关。
需要这样做
AmazonKinesisAsyncClientBuilder.standard()
.withRegion("eu-west-1")
.withCredentials(...)
.build()
与S3不同,似乎没有AmazonKinesisAsync.builder()
所以案件略有不同。