这是我的代码
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 文件时它显然存在。当我开始输入时,它甚至会自动完成该方法。
这里可能出了什么问题?
我想通了。出于某种原因,我在我的项目中使用了
com.amazonaws.services.kinesis.model
和software.amazon.awssdk.services.kinesis.model
。我使用的是一个包装中的KinesisClient
和另一个包装中的PutRecordRequest
。