Posições iniciais de sondagem e fluxo no Lambda - AWS Lambda

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.