Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Configuration de source d’événements Amazon MSK pour Lambda

Pour utiliser un cluster Amazon MSK comme source d'événements pour votre fonction Lambda, vous devez créer un mappage de source d'événements qui connecte les deux ressources. Cette page explique comment créer un mappage de source d'événements pour Amazon MSK.

Cette page suppose que vous avez déjà correctement configuré votre cluster MSK et l'Amazon Virtual Private Cloud (VPC) dans lequel il réside. Si vous devez configurer votre cluster ou votre VPC, consultez. Configuration de votre cluster Amazon MSK et de votre réseau Amazon VPC pour Lambda

Utilisation d’un cluster Amazon MSK en tant que source d’événement

Lorsque vous ajoutez votre cluster Apache Kafka ou Amazon MSK comme déclencheur pour votre fonction Lambda, le cluster est utilisé comme source d’événement.

Lambda lit les données d'événements des rubriques Kafka que vous spécifiez Topics dans une CreateEventSourceMappingdemande, en fonction de la position de départ que vous spécifiez. Lorsque le traitement a réussi, votre rubrique Kafka est validée dans votre cluster Kafka.

Lambda lit les messages séquentiellement pour chaque partition de rubrique Kafka. Une seule charge utile Lambda peut contenir des messages provenant de plusieurs partitions. Lorsque d'autres enregistrements sont disponibles, Lambda continue de traiter les enregistrements par lots, en fonction de la BatchSize valeur que vous spécifiez dans une CreateEventSourceMappingdemande, jusqu'à ce que votre fonction aborde le sujet.

Après avoir traité chaque lot, Lambda valide les décalages des messages dans celui-ci. Si votre fonction renvoie une erreur pour l’un des messages d’un lot, Lambda réessaie le lot de messages complet jusqu’à ce que le traitement réussisse ou que les messages expirent. Vous pouvez envoyer les enregistrements qui échouent à toutes les tentatives vers une destination en cas de panne pour un traitement ultérieur.