0

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 を介して同じアクセス キーを使用してみました。できます

4

1 に答える 1