使用SSIS将JSON Kafka消息消费到SQL Server表中

问题描述

我们尝试将当前的Kafka Server集成到我们的sql Server表中,但是缺少执行该操作的示例。我们想要的过程是使卡夫卡连续消耗JSON消息(如果几秒钟内没有传入消息,则需要睡眠),将其转换为临时表行,以便我们可以使用SSIS使用现有数据库中的一些查找表对其进行转换。

我们使用Confluent Client作为脚本编写的主干, 虽然它也可以在Apache Kafka中使用,但是我们对如何将消息直接推送到SSIS中感到困惑,所以我们可以使用此脚本将Kafka服务器作为SSIS的数据源,并在有新消息来自Kafka时触发SSIS进程。由于缺少示例源,我们仍然在SSIS中将脚本用于Kafka连接。

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)