Créez des plugins personnalisés - Amazon Managed Streaming for Apache Kafka

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.

Créez des plugins personnalisés

Un plugin est une AWS ressource qui contient le code qui définit la logique de votre connecteur. Vous chargez un fichier JAR (ou un fichier ZIP contenant un ou plusieurs fichiers JAR) dans un compartiment S3 et vous spécifiez l'emplacement du compartiment lorsque vous créez le plugin. Lorsque le plugin est créé, MSK Connect copie le contenu de l'objet S3 à ce moment-là. Il ne maintient pas de lien vers l'objet S3, de sorte que les modifications ultérieures apportées à l'objet n'affecteront ni le plugin ni ses connecteurs. Lorsque vous créez un connecteur, vous spécifiez le plugin que MSK Connect doit utiliser. La relation entre les plugins et les connecteurs est la suivante one-to-many : vous pouvez créer un ou plusieurs connecteurs à partir du même plugin.

Note

Les plugins personnalisés ne peuvent pas être mis à jour sur place. Pour utiliser une nouvelle version du code de votre plugin, supprimez tous les connecteurs qui font référence au plugin, supprimez le plugin, puis recréez-le.

Packaging de dépendances pour les plugins personnalisés

Nous vous recommandons d'inclure tous les fichiers JAR et dépendances requis pour votre plugin. Package de votre connecteur sous la forme de l'un des éléments suivants :

  • Un fichier ZIP contenant tous les fichiers JAR et les dépendances requis pour le plugin.

  • Un seul uber JAR contenant tous les fichiers de classe du plugin et de ses dépendances.

Le fait de ne pas regrouper les dépendances de vos plugins peut avoir un impact sur la disponibilité ou la compatibilité dans l'environnement d'exécution et provoquer des erreurs inattendues.

Pour plus d'informations sur le développement du code d'un connecteur, consultez le Guide de développement des connecteurs dans la documentation d'Apache Kafka.

Création d'un plugin personnalisé à l'aide du AWS Management Console

  1. Ouvrez la console Amazon MSK à l'adresse https://console.aws.amazon.com/msk/.

  2. Dans le volet de gauche, sous MSK Connect, choisissez Plugins personnalisés.

  3. Choisissez Créer un plugin personnalisé.

  4. Choisissez Parcourir S3.

  5. Dans la liste des compartiments S3, choisissez le compartiment contenant le fichier JAR ou ZIP du plugin.

  6. Dans la liste des objets, cochez la case située à gauche du fichier JAR ou ZIP du plugin, puis sélectionnez Choisir.

  7. Choisissez Créer un plugin personnalisé.

Pour utiliser l'API MSK Connect afin de créer un plugin personnalisé, consultez CreateCustomPlugin.