Cassandra Java driver: how many contact points is reasonable?

java cassandra cassandra-2.0
henry picture henry · Nov 10, 2014 · Viewed 20k times · Source

In Java I connect to Cussandra cluster as this:

Cluster cluster = Cluster.builder().addContactPoints("host-001","host-002").build();

Do I need to specify all hosts of the cluster in there? What If I have a cluster of 1000 nodes? Do I randomly choose few? How many, and do I really do that randomly?

Answer

Alex Popescu picture Alex Popescu · Nov 11, 2014

I would say that configuring your client to use the same list of nodes as the list of seed nodes you configured Cassandra to use will give you the best results.

As you know Cassandra nodes use the seed nodes to find each other and discover the topology of the ring. The driver will use only one of the nodes provided in the list to establish the control connection, the one used to discover the cluster topology, but providing the client with the seed nodes will increase the chance for the client to continue to operate in case of node failures.

Related questions

How to set Cassandra (>2.0) JVM heap size of 8GB?

How to set Cassandra (>2.0) JVM heap size of 8GB? When I type in free -m it gives me the following. How can I set the Cassandra JVM heap size to 8GB? total used free shared buffers cached Mem: 16047 11336 4711 0 81 5814 -/+ …

Read More
Cassandra Java Driver- QueryBuilder API vs PreparedStatements

Datastax Java driver (cassandra-driver-core 2.0.2) for Cassandra supports PreparedStatements as well as QueryBuilder API. Any specific advantages using one over the other? Disadvantages? Documentation: http://www.datastax.com/documentation/developer/java-driver/2.0/common/drivers/reference/driverReference_r.html The above doc does …

Read More
How to connect Cassandra using Java class

I am doing this to connect cassandra.But my code is returning an error.. Here is my code public class CassandraConnection { public static void main(String[] args) { String serverIp = "166.78.10.41"; String keyspace = "gamma"; CassandraConnection connection; Cluster cluster = Cluster.builder() .addContactPoints(serverIp) .…

Read More