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

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

测试和使用 Kafka Connector

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

  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 表以确认记录是否已成功插入。

语言: 中文