Publié le: Nov 16, 2023

AWS Lambda prend désormais en charge les destinations d'événements échoués pour Amazon Managed Streaming for Apache Kafka (MSK) et les mappages de sources d'événements Apache Kafka autogérés. Les destinations d'événements échoués permettent à votre fonction Lambda de continuer à traiter les événements relatifs à un sujet même si elle renvoie une erreur.

Auparavant, si une fonction AWS Lambda ne parvenait pas à traiter un message Kafka, elle retentait l'enregistrement jusqu'à l'expiration du message. Cette approche pouvait entraîner des coûts inutiles et compliquer la gestion des erreurs. Avec les destinations d'événements ayant échoué, les lots d'événements défaillants seront envoyés à SQS, SNS ou S3 après seulement quelques nouvelles tentatives. Cela garantit que les fonctions Lambda ne se bloquent pas sur un seul lot défaillant et permet de repiloter les événements ultérieurement. Les messages Kafka de plus de 6 Mo seront également envoyés à la destination de l'événement ayant échoué. Lorsque SQS ou SNS sont sélectionnés comme destination, Lambda envoie des métadonnées, y compris des informations de décalage, à la destination. Lorsque S3 est sélectionné comme destination, Lambda envoie l'enregistrement d'invocation du lot défaillant à la destination.

Cette fonctionnalité est disponible dans toutes les régions AWS où les mappages de sources d'événements Amazon MSK ou Apache Kafka autogérés sont disponibles. Cette fonctionnalité est désactivée par défaut et son utilisation ne nécessite aucun frais supplémentaire, mais vous devrez payer les frais associés à la destination souhaitée (SQS/SNS/S3). Pour en savoir plus, consultez le Guide du développeur Lambda d’Amazon MSK ou Kafka.