1

在 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 ,但这可能不相关。

4

1 回答 1

1

需要这样做

AmazonKinesisAsyncClientBuilder.standard()
  .withRegion("eu-west-1")
  .withCredentials(...)
  .build()

与 S3 不同,似乎没有,AmazonKinesisAsync.builder()所以情况略有不同。

于 2019-03-06T07:40:26.373 回答