Spring Webflux - Reactive Cassandra - 配置 ConsistencyLevel

Question

关于Spring使用反应式 Cassandra 启动 Webflux 的问题。

在以前的非反应世界中，我们可以配置 ConsistencyLevel 如下：

CassandraConfiguration extends AbstractCassandraConfiguration

    @Override
    public QueryOptions getQueryOptions() {
        QueryOptions queryOptions = new QueryOptions();
        queryOptions.setConsistencyLevel(ConsistencyLevel.TWO);
        return queryOptions;
    }

但是，使用 AbstractReactiveCassandraConfiguration 后，情况似乎发生了变化。

@RefreshScope
@Configuration
@EnableReactiveCassandraRepositories
public class BaseCassandraConfiguration extends AbstractReactiveCassandraConfiguration {

    @Override
    public QueryOptions getQueryOptions() {
        QueryOptions queryOptions = new QueryOptions();
        queryOptions.setConsistencyLevel(ConsistencyLevel.TWO);
        return queryOptions;
    }

@Override 存在问题，“方法确实从超级 class 覆盖”
并且 QueryOptions 的实现似乎已经改变。

请问在Spring Webflux 2.3.5 + reactive Cassandra 中配置一致性级别的正确方法是什么？

谢谢

Answer 1

您可以使用以下命令在自动配置的 Session 实例上配置一致性级别属性

spring.data.cassandra.consistencyLevel

Spring Webflux - Reactive Cassandra - 配置 ConsistencyLevel

Spring Webflux - Reactive Cassandra - configure ConsistencyLevel

java

cassandra

spring-webflux