我想使用它KinesisMessageDrivenChannelAdapter
从 Kinesis 流中读取记录。首次启动消费者应用程序时,我希望它接收流中已存在的所有记录。但在后续启动时,应用程序应继续从来自 DynamoDb 的最新检查点序列号读取。
我的假设是否正确,adapter.setStreamInitialSequence(KinesisShardOffset.trimHorizon())
导致了这种行为?
我想使用它KinesisMessageDrivenChannelAdapter
从 Kinesis 流中读取记录。首次启动消费者应用程序时,我希望它接收流中已存在的所有记录。但在后续启动时,应用程序应继续从来自 DynamoDb 的最新检查点序列号读取。
我的假设是否正确,adapter.setStreamInitialSequence(KinesisShardOffset.trimHorizon())
导致了这种行为?
目前如何KinesisMessageDrivenChannelAdapter
处理多个实例之间的平衡?我希望当我启动另一个实例进行扩展时,碎片分布得比较均匀。
我找到了这张旧票https://github.com/spring-projects/spring-integration-aws/issues/99。 似乎没有重新平衡。
感谢您的意见!