我有一个sql 2008 r2数据库，我想与kafka集成，所以本质上我想使用更改数据捕获来捕获表中的更改，并将它们放在kafka队列中—这是供前端开发人员从kafka读取数据的。以前有没有人这样做过，或者有没有什么建议？
svgewumm1#
kafka连接器现在将解决这个问题，特别是jdbc连接器。jdbc连接器允许您使用jdbc驱动程序将数据从任何关系数据库导入kafka主题。通过使用jdbc，这个连接器可以支持各种各样的数据库，而不需要为每个数据库编写自定义代码。资料来源：http://docs.confluent.io/3.0.0/connect/connect-jdbc/docs/jdbc_connector.html另请参见：github上的kafka connect jdbc连接器源代码Kafka连接文档
jgzswidk2#
您无法直接从sql server执行此操作。您必须编写自己的producer，将day从sql中拉出来，并推送到kafka队列。我们目前正在通过后台服务做同样的事情，将数据推送到Kafka
2条答案
按热度按时间svgewumm1#
kafka连接器现在将解决这个问题，特别是jdbc连接器。
jdbc连接器允许您使用jdbc驱动程序将数据从任何关系数据库导入kafka主题。通过使用jdbc，这个连接器可以支持各种各样的数据库，而不需要为每个数据库编写自定义代码。
资料来源：http://docs.confluent.io/3.0.0/connect/connect-jdbc/docs/jdbc_connector.html
另请参见：
github上的kafka connect jdbc连接器源代码
Kafka连接文档
jgzswidk2#
您无法直接从sql server执行此操作。您必须编写自己的producer，将day从sql中拉出来，并推送到kafka队列。我们目前正在通过后台服务做同样的事情，将数据推送到Kafka