Snowflake High Performance connector for Kafka:コネクタをテストする

このトピックでは、 Snowflake High Performance connector for Kafka コネクタ自体をテストするステップについて説明します。

Kafkaコネクタのテストと使用

Snowflakeは、本番システムでコネクタを使用する前に、少量のデータでKafkaコネクタをテストすることをお勧めします。

  1. KafkaおよびKafka Connectが実行されていることを確認します。

  2. 適切なKafkaトピックを作成したことを確認します。

  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. 設定されたKafkaトピックにデータのサンプルセットを公開します。

  7. データがシステム全体に伝播するまで数秒待ってから、Snowflakeテーブルをチェックして、記録が挿入されたことを確認します。