升级Cassandra Java Driver至4.x遇DC不匹配错误求解决方案

核心报错解决 #

你遇到的错误是因为指定的本地数据中心名称与集群实际节点的DC不匹配：代码里写的是dc1，但从报错信息看，集群节点所属的DC是ggi-l和ggi-s。首先需要确认你的应用实际部署所在的DC（或优先连接的DC），然后修正withLocalDatacenter的参数值。

完整迁移示例与建议 #

1. 修正会话初始化代码 #

推荐使用配置文件管理参数（和旧版本的properties风格兼容），也可以用代码硬编码快速验证：

方式一：代码硬编码（快速验证）

try (CqlSession session = CqlSession.builder()
        .addContactPoints(
                InetSocketAddress.createUnresolved("tfi-db-ddac-001.tfi.myCompany.net", 9042),
                InetSocketAddress.createUnresolved("tfi-db-ddac-002.tfi.myCompany.net", 9042)
        )
        // 替换为报错信息中显示的实际DC，比如应用部署在ggi-l就填这个值
        .withLocalDatacenter("ggi-l")
        .withAuthCredentials("username", "password")
        .build()) {
    // 会话业务逻辑
}

方式二：使用配置文件（推荐，和旧配置对齐）

创建application.conf（Driver 4.x支持Typesafe Config格式），对应旧配置迁移：

datastax-java-driver {
  basic.contact-points = [
    "tfi-db-ddac-001.tfi.myCompany.net:9042",
    "tfi-db-ddac-002.tfi.myCompany.net:9042"
  ]
  basic.load-balancing-policy {
    local-datacenter = "ggi-l" # 替换为实际本地DC名称
  }
  auth {
    provider = "plain-text"
    username = "username"
    password = "password"
  }
}

会话构建可简化为：

try (CqlSession session = CqlSession.builder().build()) {
    // 会话业务逻辑
}

2. Keyspace 创建逻辑迁移 #

旧版本的keyspace创建语句可直接复用，注意替换复制策略中的DC名称为集群实际值：

// 创建myKeySpace
session.execute("CREATE KEYSPACE IF NOT EXISTS myKeySpace WITH replication = {'class' : 'NetworkTopologyStrategy', 'ggi-l' : 1, 'ggi-s' : 1};");
// 创建myKeySpace_log
session.execute("CREATE KEYSPACE IF NOT EXISTS myKeySpace_log WITH replication = {'class' : 'NetworkTopologyStrategy', 'ggi-l' : 1, 'ggi-s' : 1};");

3. 一致性级别配置迁移 #

Driver 4.x支持全局默认配置和语句级单独指定：

• 全局默认写一致性级别（对应旧配置的全局设置）：
  在application.conf中添加：

  datastax-java-driver {
    basic.request {
      consistency = TWO
    }
  }
  

• 语句级指定不同一致性级别（对应旧配置中不同表的差异化设置）：

  // log_entries表写操作指定一致性级别
  session.execute(
      SimpleStatement.builder("INSERT INTO myKeySpace.log_entries (...) VALUES (...)")
          .setConsistencyLevel(ConsistencyLevel.TWO)
          .build()
  );
  // metric_monitor表同理
  session.execute(
      SimpleStatement.builder("INSERT INTO myKeySpace.metric_monitor (...) VALUES (...)")
          .setConsistencyLevel(ConsistencyLevel.TWO)
          .build()
  );
  

4. 其他迁移注意事项 #

• 依赖替换：确保构建文件中替换为Driver 4.x依赖，比如Maven：

  <dependency>
      <groupId>com.datastax.oss</groupId>
      <artifactId>java-driver-core</artifactId>
      <version>4.17.0</version> <!-- 使用最新稳定版 -->
  </dependency>
  

• API适配：Driver 4.x重构了核心API，比如旧版Cluster类被CqlSession替代，所有操作通过CqlSession执行；ResultSet遍历逻辑也有调整，需对应修改业务代码。

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