Snowflake Connector for Kafka：选择使用 时默认使用的角色和仓库。测试连接器

本主题介绍如何测试 Snowflake Connector for Kafka 连接器本身。

测试和使用 Kafka Connector

Snowflake 建议在将 Kafka Connector 用于生产系统之前，先使用少量数据对其进行测试。

  1. 验证 Kafka 和Kafka Connect是否正在运行。

  2. 验证是否已创建适当的 Kafka 主题。

  3. 创建（或使用现有的）消息发布器。确保发布到主题中的消息采用正确的格式（JSON、Avro、Protobuf）。

  4. 创建一个配置，指定要订阅的主题和要写入的 Snowflake 表。

  5. 将 Snowflake 对象（数据库、模式）所需的最低权限授予将用于引入数据的角色。

  6. 向配置的 Kafka 主题发布一组示例数据。

  7. 等待几秒钟，让数据在系统中完成传递，然后检查 Snowflake 表以确认记录是否已成功插入。