dropwizard 内で KPL を実行しています。以下は私のコードです。
AWSStaticCredentialsProvider credentialsProvider = new AWSStaticCredentialsProvider(new
BasicAWSCredentials("XXXX",
"XXXXXXXXXXXX"));
kinesis = new KinesisProducer(new KinesisProducerConfiguration()
.setCredentialsProvider(credentialsProvider)
.setRegion("ap-south-1")
.setRecordMaxBufferedTime(100)
);
ListenableFuture<UserRecordResult> future = kinesis.addUserRecord("ctm-prod", "default_partition", data);
UserRecordResult m = future.get();
future.get()
コードは永久にブロックされます。エラー メッセージは記録されません。
PS: boto と Java sdk を介して同じアクセス キーを使用してみました。できます