我在我的spring web mvc项目(spring-data-elasticsearch)中使用了elasticsearch,并与数据库同步(MySQL)。我正在从我的应用程序索引文档,如果有任何新的实体要同时添加到数据库表中,从服务层,我请求索引这个文档到elasticsearch也。db表和elasticsearch<e
我有一段java代码,它使用Spring- data -elasticsearch连接到ElasticsearchDB,并通过连接到存储库并执行findAll()方法来获取所有索引数据。从ES接收的数据正在由单独的应用程序处理。当新数据被插入到elastic search中时,我有以下查询 1.How can I fetch only the newly ins