Cassandra Replication Help Required.

(5 posts) (2 voices)

• Started 1 year ago by
• Latest reply from
• This topic is not a support question

Tags:

No tags yet.

1. 

   Anonymous
   Unregistered

   Hi Everyone,

   I have configured the cassandra cluster on single window machine and I am trying to insert the data but somehow I am not able to get replication (Same node with two replication). Here is what I am doing.

   CREATE KEYSPACE demo
   with placement_strategy = 'org.apache.cassandra.locator.SimpleStrategy'
   and strategy_options = [{replication_factor:2}];

   use demo;

   create column family order with comparator=UTF8Type and key_validation_class=UTF8Type and default_validation_class=UTF8Type and column_metadata=[{column_name: member, validation_class: UTF8Type},{column_name: user, validation_class: UTF8Type, index_type: KEYS},{column_name: instrument, validation_class: UTF8Type},{column_name: price, validation_class: DoubleType}, {column_name: quantity, validation_class: Int32Type},{column_name:datetime, validation_class: DateType}];

   set[KEY]['member'] = 'Ansar';

   it works fine if I get it from the same client but when I try to get it from different client using different server then it return 0 rows which means there is replication problem.

   Can you please help me out, how I can insert the data in both nodes ?

   -Ansar

   Posted 1 year ago #
2. 

   nickmbailey
   Key Master

   The replication_factor setting indicates how many individual nodes to store data on. Since you are only using a 1 node installation, a replication factor of 2 is invalid. If you change the replication factor to 1, things should work.

   Posted 1 year ago #
3. 

   Anonymous
   Unregistered

   nickmbailey thanks for your message but unfortunately it's not working. Well I have one node cluster and I have divided into two address 127.0.0.1 and 127.0.0.2. Using Cassandra Client if I try to insert the data into 127.0.0.1. The data successfully gets add for 127.0.0.1 and I can view it also but If I try to connect to view from 127.0.0.2, I cannot see any update. There is no data.

   I think I was unable to explain it well last time.Here is what I did copied two cassandra into different folders with the name Cassandra 1 and Cassandra 2 on same node. Update the Cassandra.yaml accordingly.

   1

   cluster_name: 'Test Cluster'
   initial_token:
   data_file_directories:
   - /Cassandra/1/var/lib/cassandra/data

   # commit log
   commitlog_directory: /Cassandra/1/var/lib/cassandra/commitlog

   # saved caches
   saved_caches_directory: /Cassandra/1/var/lib/cassandra/saved_caches

   - seeds: "127.0.0.1,127.0.0.2"

   listen_address: 127.0.0.1

   rpc_address: 127.0.0.1

   2

   cluster_name: 'Test Cluster'
   initial_token:
   data_file_directories:
   - /Cassandra/2/var/lib/cassandra/data

   # commit log
   commitlog_directory: /Cassandra/2/var/lib/cassandra/commitlog

   # saved caches
   saved_caches_directory: /Cassandra/1/var/lib/cassandra/saved_caches

   - seeds: "127.0.0.1,127.0.0.2"

   listen_address: 127.0.0.2

   rpc_address: 127.0.0.2

   The others settings are the default setting and I have not modified anything. Then I create a keyspace and column family using

   CREATE KEYSPACE demo
   with placement_strategy = 'org.apache.cassandra.locator.SimpleStrategy'
   and strategy_options = [{replication_factor:2}];

   use demo;

   create column family order with comparator=UTF8Type and key_validation_class=UTF8Type and default_validation_class=UTF8Type and column_metadata=[{column_name: member, validation_class: UTF8Type},{column_name: user, validation_class: UTF8Type, index_type: KEYS},{column_name: instrument, validation_class: UTF8Type},{column_name: price, validation_class: DoubleType}, {column_name: quantity, validation_class: Int32Type},{column_name:datetime, validation_class: DateType}];

   Now if I try to connect to 127.0.0.1 and insert the data, I belive that data should be inserted for both 127.0.0.1 and 127.0.0.2

   Is there anything wrong ? What should I do to make it workable.

   Posted 1 year ago #
4. 

   Anonymous
   Unregistered

   
   

   Posted 1 year ago #
5. 

   Anonymous
   Unregistered

   One more thing if I create keyspace using client to 127.0.0.1 then it dosenot create to 127.0.0.2.

   Posted 1 year ago #

RSS feed for this topic