我们正在使用弹簧集成-AWS-2.0.0连接到室壁运动来听流。虽然停止应用程序,总是收到以下异常。
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.
虽然它可能不会造成任何数据丢失呢。有没有人得到这个错误?
这看起来像一个简单的,但它是烦人。
我的问题得到了由上述第二个选项固定。
希望这可以帮助 :)