Elastic Search 和 Apache Ignite 之间的发布订阅

Question

我在 Ignite 中实现了自定义 CacheStore 以与 Elastic Search 通信。我的问题是，是否有任何方法可以让 Ignite 获取 Elastic Search DB 中发生的任何更改？

Answer 1

Ignite 的 CacheStore 是面向拉取的：它们从 DB 中拉取数据，但 DB 不会将更新推送到 Ignite。这是因为大多数数据库没有强大的更新通知机制（并且在 MVCC/SQL 事务的情况下，这实际上不可能在所有情况下都正确实施）。

您可以尝试在 Elasticsearch 旁边的某处启动 Ignite 的 DataStreamer，将所有更新推送给它。当然，这需要开发工作。