最赞回答 / 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