Ошибка библиотеки KPL AWS Kinesis Producer без сообщений об ошибках

Question

Я запускаю KPL внутри dropwizard. Ниже мой код.

    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: я пытался использовать те же ключи доступа через Бото и Java SDK. Оно работает

Answer 1

Попробуйте обновить версию производителя Kinesis до последней.

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