java - 获取 Amazon Kinesis 异常状态代码 : 502 when using LocalStack from Java

Question

我正在使用 LocalStack 编写集成测试来模拟我对 Kinesis 的调用。我已经创建了一个 Kinesis 客户端，但是当我尝试将记录放在 Kinesis 上时出现错误:

com.amazonaws.services.kinesis.model.AmazonKinesisException: null(服务:AmazonKinesis；状态代码:502；错误代码:null；请求 ID:null)

我试过使用以下方法禁用 CBOR 和证书检查:

System.setProperty(SDKGlobalConfiguration.DISABLE_CERT_CHECKING_SYSTEM_PROPERTY, "false");

System.setProperty(SDKGlobalConfiguration.AWS_CBOR_DISABLE_SYSTEM_PROPERTY, "true");

我这样构建客户端:

.withEndpointConfiguration(localstack.getEndpointConfiguration(LocalStackContainer.Service.KINESIS))
.withCredentials(localstack.getDefaultCredentialsProvider())
.build()

我每次都收到 502。 S3 一切正常，只是 Kinesis 服务给我带来了麻烦。有没有人见过这样的事情？

Answer 1

我在本地通过 localstack 连接 Kinesis 时遇到了类似的问题。我使用的是 v2 SDK java 库。

根本原因

默认情况下，kinesalite 不支持 CBOR，应该禁用它才能运行。互联网上充斥着禁用 CBOR 的标志，但没有一个对我有用。

你必须做两件事:

1. 设置环境变量 AWS_CBOR_DISABLE=true 告诉 localstack 停止使用
2. 设置环境变量 aws.cborEnabled=false 以告知 AWS SDK 停止使用它。

在我的例子中，我被 software.amazon.awssdk.core.SdkSystemSetting 中引用的 SDK 标记卡住了