Kafka连接器:如何使用OR运算符和递增列执行查询

Question

我使用kafkaconnect从Oracle数据库到kafka主题的源数据。我想根据增加的id或状态列从一个表中获取数据，比如SQL语句：

SELECT * from TABLE_X where ID > Y or STATUS = 'Z';

有没有可能将这两个or条件与使用incrementing.column.name连接器属性相结合？

Answer 1

您可以尝试使用query属性使用基于查询的摄取，并将其与incrementing模式相结合。

来源：Robin Moffatt 的Kafka Connect Deep Dive–JDBC Source Connector