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. Create (or use an existing) message publisher. Make sure that the messages published to the topic have the right format (JSON, Avro, Protobuf).

  4. Create a configuration that specifies the topic to subscribe to and the Snowflake table to write to.

  5. Grant the minimum privileges required on the Snowflake objects (database, schema) to the role that will be used to ingest data.

  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.