Cassandra Java 驱动程序错误 - 所有主机尝试查询失败连接已关闭

Question

全部，

我在 Digital Ocean 中有一个 3 节点集群 cassandra。根据 CQL 中 SHOW VERSION 的 cassandra 版本如下所示

[cqlsh 5.0.1 |卡桑德拉 3.0.0 | CQL 规范 3.3.1 |本机协议 v4]

我能够使用 cqlsh 和运行命令从另一个节点连接到集群的一个节点...但是当我尝试使用 java 驱动程序连接时，我得到以下信息异常

com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: /128.xxx.xxx.xx:9042 (com.datastax.driver.core.TransportException: [/128.xxx.xxx.xxx:9042] Connection has been closed))
at com.datastax.driver.core.ControlConnection.reconnectInternal(ControlConnection.java:222)
at com.datastax.driver.core.ControlConnection.connect(ControlConnection.java:77)
at com.datastax.driver.core.Cluster$Manager.init(Cluster.java:1232)
at com.datastax.driver.core.Cluster.getMetadata(Cluster.java:336)
at com.attinad.cantiz.iot.platform.vehicledatapoc.App.connect(App.java:22)
at com.attinad.cantiz.iot.platform.vehicledatapoc.App.main(App.java:14)

我使用的java驱动版本是2.0.10。 maven配置如下

<dependency>
<groupId>com.datastax.cassandra</groupId>
<artifactId>cassandra-driver-core</artifactId>
<version>2.0.10</version>
</dependency>

我检查了cassandra.yaml，发现以下设置已经正确设置

start_native_transport: true
native_transport_port: 9042
rpc_address: 128.xxx.xxx.xx
listen_address: 128.xxx.xxx.xx

已正确配置...所以我完全迷路了...感谢任何帮助

Answer 1

根据 2.0.10 driver documentation, that version of the driver is compatible with Apache Cassandra 1.2 and 2.0. Compatibility with 3.0 is added in the 3.0 driver，目前为 3.0.0-beta1。协议兼容性错误应显示在 Cassandra 服务器日志中。

您可以将 Cassandra 降级到 2.x 版本或试用测试版驱动程序。如果你现在想在生产中使用该系统，降级 Cassandra 应该是更安全的选择。

Answer 2

运行我自己……尝试过使用驱动程序 2.1.9 的 Cassandra 3.0.0。

通过驱动程序 3.0.0 修复了它。

Cassandra Java 驱动程序错误 - 所有主机尝试查询失败连接已关闭

Cassandra Java Driver error - All host(s) tried for query failed Connection has been closed

java

datastax-enterprise

datastax-java-driver

digital-ocean

cassandra-3.0