Note

Ce connecteur est soumis aux conditions d’utilisation de Snowflake Connector.

Connecteur Openflow Snowflake pour Kafka : Configuration de l’authentification AWS MSK IAM

AWS MSK IAM vous permet d’utiliser AWS Identity and Access Management (IAM) pour vous authentifier auprès d’Amazon Managed Streaming for Apache Kafka (MSK).

Conditions préalables

  • Votre cluster Kafka doit être Amazon MSK avec l’authentification IAM activée.

  • Vous devez fournir des identifiants IAM dans Openflow avec des configurations BYOC (bring your own cloud), déployées dans votre Cloud.

  • Le rôle ou l’utilisateur de IAM doit disposer des autorisations nécessaires pour MSK.

Étape 1 : Créer AmazonMSKConnectionService

À partir du canevas Openflow, accédez à la configuration des services du contrôleur :

  1. Double-cliquez sur le groupe de traitement du connecteur.

  2. Cliquez avec le bouton droit de la souris sur le canevas et sélectionnez Services de contrôleur.

Ajoutez un nouveau AmazonMSKConnectionService :

  1. Sélectionnez + pour ajouter un nouveau service de contrôleur.

  2. Sélectionnez AmazonMSKConnectionService dans la liste.

  3. Sélectionnez Ajouter.

Configurez les propriétés de AmazonMSKConnectionService :

Propriété

Valeur

Mécanisme SASL

AWS_MSK_IAM

Protocole de sécurité

#{Kafka Security Protocol}

Serveurs Bootstrap

#{Kafka Bootstrap Servers}

Vérifiez le site AmazonMSKConnectionService :

  1. Sélectionnez Vérifier pour le service.

  2. Confirmez que l’état du service indique Vérifié.

Étape 2 : Configurer le processeur ConsumeKafka

  1. Dans votre connecteur Kafka, recherchez le processeur ConsumeKafka.

  2. Configurez le processeur pour qu’il utilise le nouveau service de connexion :

    Définissez la propriété Kafka Connection Service sur le AmazonMSKConnectionService que vous avez créé dans Étape 1 : Créer AmazonMSKConnectionService.

Étape 3 (facultative) : Supprimer l’ancien service de connexion Kafka

  1. Dans l’onglet Services du contrôleur, recherchez l’ancien service Kafka3Connection.

  2. Désactivez et supprimez l’ancien service :

    1. Sélectionnez Désactiver pour l’ancien service.

    2. Une fois désactivé, sélectionnez Supprimer pour supprimer l’ancien service.