Spring Webflux - Reactive Cassandra - 配置 ConsistencyLevel

Question

关于 SpringBoot Webflux 与响应式 Cassandra 的问题。

在之前的非响应式世界中，我们可以配置 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 上有一个问题，“方法确实要从超类覆盖”

• 而且 QueryOptions 的实现似乎发生了变化。

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

谢谢

Answer 1

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

spring.data.cassandra.consistencyLevel