为什么 KenisisClient.putRecord() 不接受有效的 PutRecordRequest

问题描述 投票:0回答:1

这是我的代码

      KinesisClient kinesisClient = KinesisClient.builder().build();
      PutRecordRequest putRecordRequest = new PutRecordRequest();
      putRecordRequest.setStreamName("stream-name");
      putRecordRequest.setPartitionKey("SomeString-" + UUID.randomUUID());
      putRecordRequest.setData(ByteBuffer.wrap(data));

      PutRecordResponse putRecordResponse = kinesisClient.putRecord(putRecordRequest);

出于某种奇怪的原因,它说它无法解析

putRecord(PutRecordRequest)
方法,即使当我查看反编译的 jar 文件时它显然存在。当我开始输入时,它甚至会自动完成该方法。

这里可能出了什么问题?

java amazon-web-services spring-boot amazon-kinesis
1个回答
0
投票

我想通了。出于某种原因,我在我的项目中使用了

com.amazonaws.services.kinesis.model
software.amazon.awssdk.services.kinesis.model
。我使用的是一个包装中的
KinesisClient
和另一个包装中的
PutRecordRequest

© www.soinside.com 2019 - 2024. All rights reserved.