AWS Kinesis 启动等待时间长

Question

我使用 AWS Kinesis 和 Spring Cloud 从数据事件中心读取数据。部署结束，日志如下：

2023-09-26 14:07:30.476  INFO [,,] 9331 --- [esis-consumer-1] a.i.k.KinesisMessageDrivenChannelAdapter : The [ShardConsumer{shardOffset=KinesisShardOffset{iteratorType=AFTER_SEQUENCE_NUMBER, sequenceNumber='49644883468861416210968280224412551456184669418448486402', timestamp=null, stream='STRAM_NAME', shard='shardId-000000000000', reset=false}, state=NEW}] has been started.

在我尝试在应用程序正在侦听的流上发送消息但在“2023-09-26 14:11:12.390”收到消息后立即。

等待时间大概有4分钟左右。问题不是等待4分钟而是无法监控启动过程。 如何监控启动情况？我如何了解启动是否“卡住”并且 kinesis 流无法工作？

Answer 1

您可以为

org.springframework.integration

类别启用 DEBUG，在那里您将能够看到一些有关启动端点的日志。

从 Spring 的角度来看，这就是我能提供的最大帮助。也许您的消费者和 Kinesis 服务器之间存在一些时区差异。