How to connect to a Cassandra cluster with authentication in Java?

Question

I am using Cassandra 3.7. I am using AuthProvider to for authentication. I have tried two methods:

AuthProvider authProvider = new PlainTextAuthProvider("abcd", "xyz");
Cluster cluster = Cluster.builder().addContactPoint(node).withAuthProvider(authProvider).build();
Session session = cluster.connect();

and

Cluster cluster = Cluster.builder().addContactPoint(node)..withCredentials("abcd", "xyz").build();
Session session = cluster.connect();

I am getting the following error:

Exception in thread "main" com.datastax.driver.core.exceptions.AuthenticationException: Authentication error on host /127.0.0.1:9042: Host /127.0.0.1:9042 requires authentication, but no authenticator found in Cluster configuration
    at com.datastax.driver.core.AuthProvider$1.newAuthenticator(AuthProvider.java:40)

What is causing the error and how do I fix it?

What you are doing should work. Can you include the code you are using to actually create a connection from the cluster. — mikea
– mikea, Commented Jul 27, 2016 at 13:56

Anastasia Osintseva · Accepted Answer · 2016-07-28 08:36:57Z

1

Change value of authenticator and authorizer in cassandra.yaml:

authenticator: PasswordAuthenticator

authorizer: CassandraAuthorizer

answered Jul 28, 2016 at 8:36

Anastasia Osintseva

1008 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

How to connect to a Cassandra cluster with authentication in Java?

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related