spring - Spring Data Elasticsearch changeStream 功能（如 mongo changeStream）

Question

Spring Data Elasticsearch 是否具有 changeStream 功能，例如 mongo？我正在尝试获取数据更改。我正在处理以下场景：我们创建一个 foo 对象。这个 foo 对象可以被多个用户更新。需要将更改推送到 UI。在 mongo 中，您可以使用 ReactiveMongoTemplate changeStream 方法。

当前的 Mongo 实现 (Kotlin)

        val options = ChangeStreamOptions.builder()
            .filter(Aggregation.newAggregation(Foo::class.java,
                                               listOf(Aggregation.match(
                                                       Criteria.where("foo_id").`is`(
                                                               6)))
            )).returnFullDocumentOnUpdate().build()

    return reactiveMongoTemplate.changeStream("foo", options, Foo::class.java)
            .map { it.body }
            .doOnNext {
                print("foo update found $it")
            }
            .doOnError { print("Error") }