我在我的Macbook上进行了Datastax企业版的默认安装。我能够创建我的键空间并设置所有应用程序,包括使用solr。
我正在尝试开发一组步骤,以为我们的开发群集启用密码身份验证。
到目前为止,我已经更新了"/usr/local/dse/resources/cassandra/conf/cassandra.yaml"并更改了以下属性:
我重新启动了节点,可以使用cqlsh登录并查询我的keyspace:
此时我尝试在Session构建器上设置凭证: 主机是:
然而,我无法成功连接。因此,我添加了一个新的用户,并能够再次通过cqlsh登录,但仍无法让Java驱动程序连接。
我正在使用Gradle引入
我总是得到以下的堆栈跟踪,通过调试可以看到用户名和密码已正确设置:
这似乎应该很简单,但我被难住了。
与Cassandra驱动程序相关的我的依赖关系图如下:
英译中:
我所能看出的这两者之间的唯一区别是,“localhost”现在是一个常量,而不再是大小为1的数组。
我正在尝试开发一组步骤,以为我们的开发群集启用密码身份验证。
到目前为止,我已经更新了"/usr/local/dse/resources/cassandra/conf/cassandra.yaml"并更改了以下属性:
authenticator: PasswordAuthenticator
authorizer: CassandraAuthorizer
我重新启动了节点,可以使用cqlsh登录并查询我的keyspace:
cqlsh -u cassandra -p cassandra
此时我尝试在Session构建器上设置凭证: 主机是:
cassandra.host=localhost
Session session = keyspaceToSessionMap.get(keyspace);
if( session == null){
Cluster cluster = Cluster.builder().addContactPoints(hosts)
.withCredentials(username, password)
//.withSSL()
.build();
session = cluster.connect(keyspace);
keyspaceToSessionMap.put(keyspace,session);
}
然而,我无法成功连接。因此,我添加了一个新的用户,并能够再次通过cqlsh登录,但仍无法让Java驱动程序连接。
cqlsh -u username -p password
Connected to LocalCluster at 127.0.0.1:9042.
[cqlsh 5.0.1 | Cassandra 2.1.8.689 | DSE 4.7.3 | CQL spec 3.2.0 | Native protocol v3]
我正在使用Gradle引入
'com.datastax.cassandra:cassandra-driver-dse:2.1.9'
驱动。我总是得到以下的堆栈跟踪,通过调试可以看到用户名和密码已正确设置:
Caused by: com.datastax.driver.core.exceptions.AuthenticationException: Authentication error on host localhost/127.0.0.1:9042: Username and/or password are incorrect
at com.datastax.driver.core.Connection$8.apply(Connection.java:376)
at com.datastax.driver.core.Connection$8.apply(Connection.java:346)
这似乎应该很简单,但我被难住了。
与Cassandra驱动程序相关的我的依赖关系图如下:
+--- com.datastax.cassandra:cassandra-driver-dse:2.1.9
| \--- com.datastax.cassandra:cassandra-driver-core:2.1.9 -> 2.1.8
| +--- io.netty:netty-handler:4.0.27.Final
| | +--- io.netty:netty-buffer:4.0.27.Final
| | | \--- io.netty:netty-common:4.0.27.Final
| | +--- io.netty:netty-transport:4.0.27.Final
| | | \--- io.netty:netty-buffer:4.0.27.Final (*)
| | \--- io.netty:netty-codec:4.0.27.Final
| | \--- io.netty:netty-transport:4.0.27.Final (*)
| +--- com.google.guava:guava:14.0.1 -> 18.0
| \--- com.codahale.metrics:metrics-core:3.0.2
| \--- org.slf4j:slf4j-api:1.7.5 -> 1.7.12
英译中:
我创建了以下通过的测试。
Cluster cluster = Cluster.builder().addContactPoints("localhost")
.withCredentials("username", "password")
//.withSSL()
.build();
Session session = cluster.connect("keyspace");
Assert.assertNotNull(session);
我所能看出的这两者之间的唯一区别是,“localhost”现在是一个常量,而不再是大小为1的数组。