Как обрабатывать данные о поздних поступлениях соединителя источника в базу данных при мониторинге последнего обновленного столбца даты в таблице - PullRequest
0 голосов
/ 19 июня 2019

Как обрабатывать данные о поздних поступлениях соединителя источника в базу данных при мониторинге последнего обновленного столбца даты в таблице.Мы пропустили данные Prasad6 в теме из-за позднего прибытия.

Table Name:     **table1**              


Sno name last_update_date
-------------------------
1    Prasad  2019-06-17 3:50:34  
2    Prasad2     2019-06-17 3:50:58  
3    Prasad3    2019-06-17 3:50:58  
4    Prasad4    2019-06-17 3:51:20  
5    Prasad5    2019-06-17 5:00:44  
6    **Prasad6  2019-06-17 4:59:00**  
7    Prasad7    2019-06-17 5:59:00  



Topic:  **connect-offsets**         

key.value value.timestamp
-------------------------
jdbc_source_table1  2019-06-17 3:51:20  
jdbc_source_table1  2019-06-17 5:00:44  
jdbc_source_table1  2019-06-17 5:59:00  
...