Согласно объединенной документации, когда мы используем режим запроса, мы должны управлять смещением. Насколько я понимаю, нам нужно отслеживать последнюю обновленную временную метку и передавать ее в предложении where при каждом перезапуске программы. Может ли кто-нибудь подтвердить правильность понимания? Заранее цените вашу помощь!
Управление смещением - Конфлюентный соединитель JDBC в режиме запроса
Ответы (1)
Вы можете сделать и то, и другое - вы все равно можете установить метку времени и режим увеличения в дополнение к запросу. он просто добавит оператор where на основе поля timestamp.column.name и / или incrementing.column.name. Вы даже можете использовать подзапрос, если вашему запросу нужен оператор where
В качестве примера вы можете задать свой запрос: выберите * из (выберите яблоки из дерева, где цвет = зеленый) в качестве подзапроса
с timestamp.column.name, установленным для рипедирования, sql kafka выполнит:
выберите * из (выберите яблоки из дерева, где цвет = зеленый) в качестве подзапроса, где ripedate> offsetdate
person
pwherman73
schedule
27.03.2018
