Мы используем spring-integration-aws-2.0.0 для подключения к kinesis для прослушивания потока. При остановке приложения всегда возникает следующее исключение.
a.i.k.KinesisMessageDrivenChannelAdapter : Got an exception java.lang.IllegalStateException: Connection pool shut down during [ShardConsumer{shardOffset=KinesisShardOffset{iteratorType=TRIM_HORIZON, sequenceNumber='null', timestamp=null, stream='developer-entitlement-command-stream-local', shard='shardId-000000000000', reset=false}, state=CONSUME}] task invocation.
Process will be retried on the next iteration.
хотя это, вероятно, еще не привело к потере данных. Кто-нибудь получил эту ошибку?




Это кажется простым, но это раздражает.
Моя проблема была исправлена вторым вариантом выше.
Надеюсь это поможет :)
Клиенты amazon kinesis настраиваются как Spring bean с помощью AmazonKinesisAsyncClientBuilder.standard()..build(). Следовательно, мы не открываем/закрываем какое-либо соединение вручную. У меня нет никакого процесса в фоне.