我想知道是否可以将 com.datastax.cassandra:cassandra-driver-core:2.0.0-beta2 与 org.apache.cassandra:cassandra-all:1.2.1一起使用。我正在使用 cassandra-maven-plugin:1.2.1-1(它使用 org.apache.cassandra:cassandra-all:1.2.1),添加...
我认为问题的关键在于
这是不是意味着2.0.0-beta2驱动程序不能与Cassandra 1.2.1一起使用?驱动程序/服务器兼容性矩阵在哪里可以找到?
我已经花了将近一天的时间来解决这个问题。
谢谢, Matthew
start_native_transport: true
native_transport_port: ${cassandra.nativePort}
将yaml
插件属性添加到配置文件后,我可以成功通过telnet连接端口。
但是,当我尝试通过以下代码进行连接时,
// Ports.NATIVE has the same value as "${cassandra.nativePort}" above
Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1")
.withPort(Ports.NATIVE).build();
Session session = cluster.connect();
I get the following exception:
com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: /127.0.0.1 (com.datastax.driver.core.ConnectionException: [/127.0.0.1] Unexpected error during transport initialization (com.datastax.driver.core.TransportException: [/127.0.0.1] Unexpected exception triggered (com.datastax.driver.core.exceptions.DriverInternalError: Server response from unsupported protocol version: 1))))
at com.datastax.driver.core.ControlConnection.reconnectInternal(ControlConnection.java:179)
at com.datastax.driver.core.ControlConnection.connect(ControlConnection.java:77)
at com.datastax.driver.core.Cluster$Manager.init(Cluster.java:868)
at com.datastax.driver.core.Cluster$Manager.newSession(Cluster.java:888)
at com.datastax.driver.core.Cluster$Manager.access$200(Cluster.java:792)
at com.datastax.driver.core.Cluster.connect(Cluster.java:155)
我认为问题的关键在于
Server response from unsupported protocol version: 1
。这是不是意味着2.0.0-beta2驱动程序不能与Cassandra 1.2.1一起使用?驱动程序/服务器兼容性矩阵在哪里可以找到?
我已经花了将近一天的时间来解决这个问题。
谢谢, Matthew