KCL прекращает обработку данных после выдачи ошибки. Отмена подписки и перезапуск. - PullRequest
Новая
       32

KCL прекращает обработку данных после выдачи ошибки. Отмена подписки и перезапуск.

0 голосов
/ 28 апреля 2020

KCL

ShardConsumerSubscriber: 131 - shardId-000000000000: последний запрос был отправлен в 2020-04-28T12: 57: 25.166Z, но по состоянию на 2020-04-28T12: 58 ответа нет: 58: 00.435Z (PT35.269S). Отмена подписки и перезапуск. " Но никогда не перезапускает приложение и никакие данные после этого не обрабатываются. Используется зависимость Maven 

<dependency>
            <groupId>software.amazon.kinesis</groupId>
            <artifactId>amazon-kinesis-client</artifactId>
            <version>2.2.2</version>
</dependency>

И конфигурация Kinesis 

KinesisAsyncClient kinesisClient = KinesisAsyncClient.builder()
                .credentialsProvider(new MyCredentialProvider(configVals)).region(region).build();
InitialPositionInStreamExtended initialPositionInStreamExtended = InitialPositionInStreamExtended
        .newInitialPosition(InitialPositionInStream.TRIM_HORIZON);
RetrievalConfig retrievalConfig = configsBuilder.retrievalConfig()
        .retrievalSpecificConfig(new PollingConfig(configVals.getStreamName(), kinesisClient)
                .idleTimeBetweenReadsInMillis(10000).maxRecords(50).kinesisRequestTimeout(Duration.ofSeconds(100)));
retrievalConfig.initialPositionInStreamExtended(initialPositionInStreamExtended);
...