Gostaria de usar KinesisMessageDrivenChannelAdapterpara ler registros de um fluxo do Kinesis. Ao iniciar o aplicativo do consumidor pela primeira vez, gostaria que ele recebesse todos os registros que já existem no fluxo. Em inicializações subsequentes, no entanto, o aplicativo deve continuar lendo do último número de sequência de checkpoint vindo do DynamoDb.
Minha suposição está correta ao adapter.setStreamInitialSequence(KinesisShardOffset.trimHorizon())fornecer esse comportamento?