我正在使用kafka connect将源数据从oracle数据库连接到kafka主题。我想根据增加的id或status列从一个表中获取数据，如sql语句： SELECT * from TABLE_X where ID > Y or STATUS = 'Z'; 有没有可能把这两者结合起来 or 使用条件 incrementing.column.name 连接器属性？
SELECT * from TABLE_X where ID > Y or STATUS = 'Z';
or
incrementing.column.name
txu3uszq1#
您可以尝试使用 query 属性并将其与 incrementing 模式。来源：kafka connect deep-dive-jdbc source connector作者：robin moffatt
query
incrementing
1条答案
按热度按时间txu3uszq1#
您可以尝试使用
query属性并将其与incrementing模式。来源：kafka connect deep-dive-jdbc source connector作者：robin moffatt