我们尝试将当前的kafka服务器集成到sqlserver表中，但缺少如何实现的示例。我们需要的过程是不断地使用来自kafka的json消息（如果几秒钟内没有传入消息，则需要睡眠），将其转换为临时表行，这样我们就可以使用现有数据库中的一些查找表使用ssis对其进行转换。
我们使用confluent client作为脚本的 Backbone.js ，因为apache kafka也提供了它，但是我们不知道如何将消息直接推入ssis，因此我们可以使用此脚本将kafka服务器作为ssis的数据源，如果有新消息来自kafka，则触发ssis进程。由于缺少示例源代码，我们仍然在ssis中使用kafka连接脚本。