Kafka Connect 和自定义查询

Question

我有兴趣使用 Kafka 源 JDBC 连接器来执行向 Kafka 的发布，以便在创建发票时执行。在源端，它分为 2 个表 Invoice 和 InvoiceLine。

这可能吗，使用自定义查询。查询会是什么样子？

此外，自投票以来，发布的内容可能包含一个主题中的一张或多张发票？

谢谢

Answer 1

是的，您可以使用自定义查询。来自docs：

自定义查询：源连接器支持使用自定义查询而不是复制整个表。使用自定义查询，只要可以将必要的WHERE 子句正确附加到查询，就可以使用其他更新自动更新模式之一。或者，指定的查询可以自己处理对新更新的过滤；但是，请注意不会执行偏移跟踪（与自动模式不同，其中为每条记录记录 incrementing 和/或 timestamp 列值），因此查询必须自己跟踪偏移。