Snowflake High Performance connector for Kafka : Tester le connecteur

Cette rubrique décrit les étapes à suivre pour tester le connecteur Snowflake High Performance connector for Kafka proprement dit.

Test et utilisation du connecteur Kafka

Snowflake recommande de tester le connecteur Kafka avec une petite quantité de données avant de l’utiliser dans un système de production.

  1. Vérifiez que Kafka et Kafka Connect sont en cours d’exécution.

  2. Vérifiez que vous avez créé le sujet Kafka approprié.

  3. Créez un éditeur de message (ou utilisez un existant). Assurez-vous que les messages publiés dans le sujet ont le bon format (JSON ou Avro).

  4. Créez un fichier de configuration spécifiant le sujet auquel vous souhaitez vous abonner et la table Snowflake dans laquelle écrire.

  5. Attribuez les privilèges minimum requis sur les objets Snowflake (base de données, schéma, table cible, etc.) au rôle qui sera utilisé pour ingérer des données.

  6. Publiez un exemple de jeu de données dans le sujet Kafka configuré.

  7. Attendez quelques secondes que les données se propagent dans le système, puis consultez la table Snowflake pour vérifier que les enregistrements ont été insérés.