Posiciones iniciales de flujos y sondeo en Lambda
El parámetro StartingPosition indica a Lambda cuándo debe empezar a leer los mensajes del flujo. Existen tres opciones entre las que elegir:
-
Más reciente: Lambda comienza a leer justo después del registro más reciente del tema de Kafka.
-
Recortar horizonte: Lambda comienza a leer a partir del último registro sin recortar en el tema de Kafka. Este también es el registro más antiguo del tema.
-
En la marca de tiempo: Lambda comienza a leer a partir de una posición definida por una marca de tiempo, en segundos de tiempo Unix. Use el parámetro StartingPositionTimestamp para especificar la marca de tiempo.
El sondeo de flujos durante la creación y la actualización de la asignación de orígenes de eventos es, en última instancia, coherente:
-
Durante la creación de la asignación de orígenes de eventos, es posible que se demore varios minutos en iniciar el sondeo de los eventos del flujo.
-
Durante las actualizaciones de la asignación de orígenes de eventos, es posible que se demore hasta 90 segundos en detener y reiniciar el sondeo de los eventos del flujo.
Este comportamiento significa que, si especifica LATEST como posición inicial del flujo, la asignación de orígenes de eventos podría omitir eventos durante una creación o actualización. Para asegurarse de que no se omita ningún evento, especifique TRIM_HORIZON o AT_TIMESTAMP.
