在 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
仅适用于默认值吗?
使用适用于 Java 的 AWS 开发工具包 2.5.1
计划通过AlpakkaKinesis阅读 Kinesis ,但这可能不相关。