java - 如何使用 Elasticsearch 从索引同步数据库

Question

我有一个用例，其中 Elasticsearch 索引和 MySQL 数据库应保持同步并满足以下条件。

1）每当我在 Elasticsearch 索引中插入/更新/删除时，它都应该与数据库（MySQL）同步。

2) 这种同步应该立即完成。

3) 对于 Elasticsearch 索引，我可以随时使用任意数量的请求进行插入/更新/删除。

如何使用 Elasticsearch 做到这一点？

谢谢！！

Answer 1

看看这个 - ES 的监听器

所以这本质上是一个监听器，当索引被更新/删除时被调用。所以重写方法 postCreate 、 postIndex 和 postDelete 并相应地更新 MySQl DB