java - 连接到 Cassandra 集群时 Java 应用程序（Wasabi）失败

Question

我正在开发 Wasabi - A/B 测试工具。我使用 Cassanra DB(3.11) 和 Datastax 驱动程序(3.5.0)。应用程序在单个 Cassandra 节点上启动良好，但在多个节点上失败。例外是：

77467 [main] ERROR c.i.w.c.d.DefaultCassandraDriver - Exception occurred while connecting to the cluster...
com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (no host was tried)

答案：

DefaultCassandraDriver.class 有配置：

builder.withLoadBalancingPolicy（新 TokenAwarePolicy（新 DCAwareRoundRobinPolicy.Builder（）...

DCAwareRoundRobinPolicy 不起作用，它与 RoundRobinPolicy 一起使用（它可以在那里配置）。我不知道有什么影响，也许只是缺少配置。

我想向 Wasabi 和任何其他 Datastax 用户指出这一点

Answer 1

回答：

DefaultCassandraDriver.class 有配置：

builder.withLoadBalancingPolicy( 
    new TokenAwarePolicy( 
      new DCAwareRoundRobinPolicy.Builder() 
...

DCAwareRoundRobinPolicy 不起作用，它与 RoundRobinPolicy 一起使用（它可以在那里配置）。我不知道有什么影响，也许只是缺少配置。

我想向 Wasabi 和任何其他 Datastax 用户指出这一点