Cassandra4.X自定义重试策略一致性级别异常及触发验证问题

问题1：CustomRetryPolicy在重试时是否使用配置的一致性级别？ #

自定义重试策略默认会沿用原查询的一致性级别，除非你在重试决策中显式指定了其他级别。也就是说，如果你的CustomRetry实现中没有修改一致性级别，重试时会使用原查询设置的EACH_QUORUM；但如果在返回重试决策时指定了新的级别，就会使用指定值。

问题2：为何报错中一致性级别为LOCAL_ONE？ #

报错显示一致性级别为LOCAL_ONE，大概率是你的CustomRetry类的onWriteTimeout方法返回了使用LOCAL_ONE的重试决策。比如代码中可能存在类似这样的逻辑：

@Override
public RetryDecision onWriteTimeout(WriteTimeoutContext context) {
    // 错误地指定了LOCAL_ONE作为重试的一致性级别
    return RetryDecision.retry(ConsistencyLevel.LOCAL_ONE);
}

另外也需要排查：

• 确认writeCL变量确实被赋值为ConsistencyLevel.EACH_QUORUM，没有在代码分支中被意外覆盖
• 检查是否有其他驱动拦截器、扩展逻辑修改了查询的一致性级别

问题3：如何确保重试被触发？ #

要保证重试逻辑被触发，需做好以下几点：

• 在CustomRetry的onReadTimeout和onWriteTimeout方法中，根据场景返回正确的重试决策：

  @Override
  public RetryDecision onWriteTimeout(WriteTimeoutContext context) {
      // 示例：满足条件时返回重试决策，沿用原一致性级别
      if (context.getRetryReason() == WriteTimeoutReason.WRITE) {
          return RetryDecision.retry(null);
      }
      // 不满足条件时返回放弃
      return RetryDecision.rethrow();
  }
  

• 确保重试条件的判断逻辑符合业务预期，比如针对可重试的超时场景返回重试决策，而非直接抛出异常
• 在重试策略方法中添加日志输出，打印进入方法的上下文参数、返回的决策类型，验证重试逻辑是否被执行
• 检查驱动配置中的重试次数限制（如basic.retry-policy.max-retries），确保配置值大于0，避免因次数限制导致重试不触发

内容的提问来源于stack exchange，提问作者Poorni