Я использую JDBC-коннектор в режиме «временной метки» для запроса таблицы CDC в SQL Server.Таблица содержит только одну запись, и соединитель извлекает эту запись при каждом опросе.
Соединитель использует это условие:
WHERE "tran_begin_time" > ? AND "tran_begin_time" < ? ORDER BY "tran_begin_time" ASC'
Со следующими параметрами:
Executing prepared statement with timestamp value = <strong>2019-09-19 15:29:46.833</strong> end time = 2019-09-21 15:08:53.510
Запрос возвращает запись, которая должна быть отфильтрована:
DEBUG || Returning 1 records for TimestampIncrementingTableQuerier{table=null, query='SELECT TOP 5000 tran_begin_time...
TRACE || WorkerSourceTask{id=cdc_companies.json-0} Appending record with key null, value Struct{tran_begin_time=<strong>2019-09-19 15:29:46.833</strong>