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);