最贊回答 / Promise丶澄明
假設第一次掃描結束時,時間節點為t1,而且這個時間節點有兩條數據A和B,其中B沒掃到,如果后面還是按大于t1掃描,就會漏掉B。如果我們的策略是第一次掃描直接放棄t1時間節點的數據,即update_time<now()。這樣下次掃描就可以掃到了,因為sql_last_value是小于t1的,update_time>:sql_last_value就包含了A和B。簡而言之,往前看一個步驟就可以理解了。
2021-09-10
最贊回答 / CagyJ
input { jdbc { jdbc_driver_library => "D:\\data_of_programming\\L2R\\ElasticSearch\\logstash-6.3.2\\mysql-connector-java-5.1.44.jar"? ? ? ? jdbc_driver_class => "com.mysql.jdbc.Driver"? ? ? ? jdbc_connection_string => "jdbc:mysql://localhost:330...
2021-07-16
最新回答 / weixin_慕哥9071923
您好!你解決了沒有,我現在也遇到相同的問題:這段代碼:
Page<EsBlog>?search?=?(Page<EsBlog>)?esBlogRepository.search(builder); List<EsBlog>?content?=?search.getContent();也是報錯:Page 1 of 1 containing UNKNOWN? instances
2021-05-13