Posições iniciais de sondagem e fluxo no Lambda
O parâmetro StartingPosition informa ao Lambda quando começar a ler as mensagens do fluxo. Existem três opções à escolha:
-
Mais recente: o Lambda começa a ler imediatamente depois do registro mais recente no tópico do Kafka.
-
Horizonte de corte: o Lambda começa a ler o tópico a partir do último registro não cortado do tópico do Kafka. Esse registro também é o mais antigo do tópico.
-
No timestamp: o Lambda começa a ler a partir de uma posição definida por um timestamp, em segundos de hora Unix. Use o parâmetro StartingPositionTimestamp para especificar o timestamp.
A pesquisa de fluxo durante a criação ou atualização de um mapeamento da origem do evento acaba sendo consistente:
-
Durante a criação do mapeamento da origem do evento, pode levar alguns minutos para a sondagem de eventos do fluxo iniciar.
-
Durante as atualizações do mapeamento da origem do evento, a pesquisa de eventos de fluxo pode levar até 90 minutos para parar e recomeçar.
Esse comportamento significa que, se você especificar LATEST como posição inicial do fluxo, o mapeamento da origem do evento poderá ignorar alguns eventos durante a criação ou a atualização. Para garantir que nenhum evento seja ignorado, especifique TRIM_HORIZON ou AT_TIMESTAMP.
