Kafka Connect和自定义查询

Question

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

是否可以使用自定义查询。查询是什么样的？

自从进行投票以来，发布的内容可能在一个主题中包含一个或多个发票？

谢谢

Answer 1

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

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