2

我们正在使用 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.

尽管它可能尚未造成任何数据丢失。有人遇到这个错误吗？

4

1 回答 1

1

这看起来很简单，但很烦人。

  • 停止应用程序时，请确保连接已关闭并将它们返回到池中。
  • 关闭应用程序时，不应在后台运行任何引用或进程。

我的问题通过上面的第二个选项得到了解决。

希望这可以帮助 ：）

于 2019-02-05T14:51:27.513 回答