将数据从 Snowflake 移动到 Kafka

Question

Snowflake 连接器（和其他工具）很好地覆盖了 Kafka => Snowflake 路径。如果将数据移向另一个方向呢？

有人使用过带有 Snowflake 的通用 JDBC 源 Kafka 连接器吗？

总体思路是让一些 Snowflake 表的内容在 Kafka 中可用。一种以足够大的间隔（例如一小时/一天）运行的更改数据捕获/快照。

有什么经验可以分享吗？还有其他想法吗？

Answer 1

如果有人仍在寻找答案，可以使用 Kafka Connect JDBC Source Connector。这是分步指南。

这是高级流程：

• 创建一个雪花实例。
• 创建卡夫卡环境
• 设置 Confluence Kafka 连接 JBDC 源连接器。
• 安装 Snowflake JDBC 驱动程序。
• 运行 Kafka Connector 并进行健全性检查。
• 最后一步：查看更改数据是否被捕获！