使用 Spring Data Cassandra 进行实时流式传输（反应式）答案

【问题标题】：Live Streaming using Spring Data Cassandra (reactive)使用 Spring Data Cassandra 进行实时流式传输（反应式）
【发布时间】：2019-07-11 13:38:10
【问题描述】：

有没有办法使用 spring-data-cassandra 实时流数据？基本上，我想在数据库有新添加时向客户端发送数据。

这就是我想要做的：-

@GetMapping(path = "mapping", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
public Flux<Mapping> getMapping() {
    Flux<Mapping> flux = reactiveMappingByExternalRepository.findAll();

    Flux<Long> durationFlux = Flux.interval(Duration.ofSeconds(1));

    return Flux.zip(flux, durationFlux).map(Tuple2::getT1);
}

但是一旦流完成它就不会返回。

【问题讨论】：

标签： java reactive-programming spring-webflux server-sent-events spring-data-cassandra

【解决方案1】：

简短的回答是否定的，没有通过 Cassandra 驱动程序实时流式传输实时更改。虽然 Cassandra 有一个 CDC（更改数据捕获），但它的级别非常低，您需要在服务器上使用提交日志。详情请见Listen to a cassandra database with datastax。

【讨论】：