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

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

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

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

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

3. メッセージパブリッシャーを作成（または既存のメッセージパブリッシャーを使用）します。トピックに公開されたメッセージが正しい形式（JSON またはAvro）であることを確認します。

4. サブスクライブするトピックと、書き込むSnowflakeテーブルを指定する構成ファイルを作成します。

5. Snowflakeオブジェクト（データベース、スキーマ、ターゲットテーブルなど）に必要な最小限の権限を、データの取り込みに使用されるロールに付与します。

6. 設定されたKafkaトピックにデータのサンプルセットを公開します。

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