Snowflake Connector for Kafka:コネクタをテストする¶

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

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

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

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

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

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

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

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

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