Publié le: Jun 21, 2023
AWS Lambda permet désormais de démarrer à partir d'un horodatage spécifique lorsque vous utilisez Amazon Managed Streaming pour Apache Kafka (MSK) ou Self-Managed Kafka comme source d'événements. Auparavant, les mappages de sources d'événements de Kafka ne pouvaient avoir que des positions de départ correspondant à Trim Horizon ou ultérieur. Désormais, en commençant par un horodatage, vous pouvez commencer à traiter les messages à un moment précis. Cela est utile dans des situations telles que la reprise après sinistre, où vous avez besoin d'un nouveau client pour reprendre rapidement le traitement là où vous l'aviez arrêté.
Lorsqu'un mappage de source d'événement Kafka est configuré pour démarrer à partir d'un horodatage spécifique, le mappage de source d'événements commence à traiter les messages d'une rubrique à partir de l'horodatage spécifié ou du premier message suivant cet horodatage. Pour utiliser cette fonctionnalité, créez un nouveau mappage de source d'événements Kafka, définissez StartingPosition sur AT_TIMESTAMP et définissez StartingPositionTimestamp sur la position de départ souhaitée. Le StartingPositionTimestamp doit être formaté en secondes Unix. Veuillez noter que dans Kafka, la position de départ n'est utilisée que pour un nouveau groupe de consommateurs ou lorsqu'un groupe de consommateurs existant pointe vers un décalage non valide (expiration). Les nouveaux mappages de sources d'événements Kafka généreront un nouvel ID de groupe de consommateurs s'ils ne sont pas configurés autrement avec un ID de groupe de consommateurs spécifique.
Cette fonction n'entraîne aucuns frais supplémentaires. Vous payez pour les invocations Lambda déclenchées par le mappage des sources d'événements connecté à Kafka. Pour en savoir plus, consultez le Guide du développeur Lambda pour Amazon MSK et Apache Kafka.