Positions de départ des interrogations et flux Apache Kafka dans Lambda
Le paramètre StartingPosition indique à Lambda quand commencer à lire les messages depuis votre flux Amazon MSK ou Apache Kafka autogéré. Vous avez le choix entre trois options :
-
Dernier : Lambda commence à lire juste après l’enregistrement le plus récent de la rubrique Kafka.
-
Supprimer l’horizon : Lambda commence par le dernier enregistrement non découpé de la rubrique Kafka. Il s’agit également de l’enregistrement le plus ancien de la rubrique.
-
À l’horodatage : Lambda commence à lire à partir d’une position définie par un horodatage, en secondes Unix. Utilisez le paramètre StartingPositionTimestamp pour spécifier l’horodatage.
L’interrogation des flux lors des mises à jour et de la création du mappage des sources d’événements est finalement cohérente :
-
Lors de la création du mappage des sources d’événements, le démarrage de l’interrogation des événements depuis le flux peut prendre plusieurs minutes.
-
Lors des mises à jour du mappage des sources d’événements, l’arrêt et le redémarrage de l’interrogation des événements depuis le flux peuvent prendre jusqu’à 90 secondes.
Ce comportement signifie que si vous spécifiez LATEST comme position de départ du flux, le mappage des sources d’événements peut manquer des événements lors d’une création ou d’une mise à jour. Pour vous assurer qu’aucun événement n’est manqué, spécifiez TRIM_HORIZON ou AT_TIMESTAMP.
