Créez un connecteur

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

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

2. Dans le volet gauche, sous MSKConnect, choisissez Connectors.

3. Sélectionnez Créer un connecteur.

4. Vous pouvez choisir entre utiliser un plugin personnalisé existant pour créer le connecteur ou créer d'abord un nouveau plugin personnalisé. Pour plus d'informations sur les plugins personnalisés et sur la façon de les créer, consultez Créez des plugins personnalisés. Dans cette procédure, supposons que vous souhaitez utiliser un plugin personnalisé. Dans la liste des plugins personnalisés, recherchez celui que vous souhaitez utiliser, cochez la case située à gauche, puis choisissez Suivant.

5. Entrez un nom et, éventuellement, une description.

6. Choisissez le cluster auquel vous souhaitez vous connecter.

7. Spécifiez la configuration du connecteur. Les paramètres de configuration que vous devez spécifier dépendent du type de connecteur que vous souhaitez créer. Cependant, certains paramètres sont communs à tous les connecteurs, par exemple les paramètres connector.class et tasks.max. Voici un exemple de configuration pour le connecteur récepteur Confluent Amazon S3.

   connector.class=io.confluent.connect.s3.S3SinkConnector
   tasks.max=2
   topics=my-example-topic
   s3.region=us-east-1
   s3.bucket.name=my-destination-bucket
   flush.size=1
   storage.class=io.confluent.connect.s3.storage.S3Storage
   format.class=io.confluent.connect.s3.format.json.JsonFormat
   partitioner.class=io.confluent.connect.storage.partitioner.DefaultPartitioner
   key.converter=org.apache.kafka.connect.storage.StringConverter
   value.converter=org.apache.kafka.connect.storage.StringConverter
   schema.compatibility=NONE

8. Vous configurez ensuite la capacité de votre connecteur. Vous pouvez choisir entre deux modes de capacité : provisionné et mis à l'échelle automatiquement. Pour plus d'informations sur ces deux options, consultez la section Comprendre la capacité du connecteur.

9. Choisissez la configuration de worker par défaut ou une configuration de worker personnalisée. Pour plus d'informations sur la création des configurations de worker par défaut, consultez Employés de MSK Understand Connect.

10. Vous spécifiez ensuite le rôle d'exécution du service. Il doit s'agir d'un IAM rôle que MSK Connect peut assumer et qui accorde au connecteur toutes les autorisations dont il a besoin pour accéder aux AWS ressources nécessaires. Ces autorisations dépendent de la logique du connecteur. Pour plus d'informations sur la création de ce rôle, consultez Comprendre le rôle d'exécution des services.

11. Choisissez Suivant, passez en revue les informations de sécurité, puis choisissez à nouveau Suivant.

12. Définissez les options de journalisation souhaitées, puis sélectionnez Suivant. Pour de plus amples informations sur la journalisation, veuillez consulter Journalisation pour MSK Connect.

13. Sélectionnez Créer un connecteur.