我们有一个用例,在这个用例中,业务逻辑要求我们从不同的数据库中连接表,并将最终结果推送到一个输入主题中。
table1 from schema1 in database1
table2 from schema2 in database2
业务逻辑
SELECT a,b FROM table1 INNER JOIN table2 ON table1.c = table2.d;
此处 a
是来自 table1
和 b
是来自 table2
,输入主题中的信息值看起来像是 { "payload":{ "a":xyz,"b":xyz} }
有没有办法用一个jdbc源连接器来实现这个要求?
PS:
简短的回答。不,你不能以这种方式使用JDBC Source连接器。
较长的答案:不,你不能以这种方式使用JDBC源连接器。JDBC源连接器可以连接到每个连接器实例中的一个数据库。你有几个选择。
query
选项。根据数据量和查询的复杂度,我个人会选择方案1,ksqlDB在这里是一个完美的选择。