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

0

尝试将 kinesis producer 版本升级到最新版本。

https://github.com/awslabs/amazon-kinesis-producer/issues/81

于 2018-08-06T12:19:46.540 回答