Hi Patrik, Thank you for your response. I am using lower version of cassandra. After upgrade to 3.4.0. It is working.
Regards, Rajesh On Friday, April 8, 2016 at 10:04:40 PM UTC+5:30, Patrik Nordwall wrote: > > Are you using Cassandra 3.x? Read up on the compatibility aspects in the > README: https://github.com/akka/akka-persistence-cassandra > > On Wed, Apr 6, 2016 at 5:59 AM, Madabhattula Rajesh Kumar < > [email protected] <javascript:>> wrote: > >> Hi, >> >> If I use below application.conf (default settings). >> >> akka { >> persistence { >> journal.plugin="cassandra-journal" >> snapshot-store.plugin="cassandra-snapshot-store" >> } >> } >> >> I got below exception >> >> Starting ........................ >> SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder". >> SLF4J: Defaulting to no-operation (NOP) logger implementation >> SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for >> further details. >> [INFO] [04/06/2016 09:26:31.933] >> [persistent-actors-akka.actor.default-dispatcher-4] >> [akka://persistent-actors/user/$a] Message >> [com.akka.persistence.Counter$Cmd] from >> Actor[akka://persistent-actors/deadLetters] to >> Actor[akka://persistent-actors/user/$a#1418786537] was not delivered. [1] >> dead letters encountered. This logging can be turned off or adjusted with >> configuration settings 'akka.log-dead-letters' and >> 'akka.log-dead-letters-during-shutdown'. >> [INFO] [04/06/2016 09:26:31.933] >> [persistent-actors-akka.actor.default-dispatcher-4] >> [akka://persistent-actors/user/$a] Message >> [com.akka.persistence.Counter$Cmd] from >> Actor[akka://persistent-actors/deadLetters] to >> Actor[akka://persistent-actors/user/$a#1418786537] was not delivered. [2] >> dead letters encountered. This logging can be turned off or adjusted with >> configuration settings 'akka.log-dead-letters' and >> 'akka.log-dead-letters-during-shutdown'. >> [INFO] [04/06/2016 09:26:31.933] >> [persistent-actors-akka.actor.default-dispatcher-4] >> [akka://persistent-actors/user/$a] Message >> [com.akka.persistence.Counter$Cmd] from >> Actor[akka://persistent-actors/deadLetters] to >> Actor[akka://persistent-actors/user/$a#1418786537] was not delivered. [3] >> dead letters encountered. This logging can be turned off or adjusted with >> configuration settings 'akka.log-dead-letters' and >> 'akka.log-dead-letters-during-shutdown'. >> [INFO] [04/06/2016 09:26:31.933] >> [persistent-actors-akka.actor.default-dispatcher-4] >> [akka://persistent-actors/user/$a] Message [java.lang.String] from >> Actor[akka://persistent-actors/deadLetters] to >> Actor[akka://persistent-actors/user/$a#1418786537] was not delivered. [4] >> dead letters encountered. This logging can be turned off or adjusted with >> configuration settings 'akka.log-dead-letters' and >> 'akka.log-dead-letters-during-shutdown'. >> *[WARN] [04/06/2016 09:26:48.321] >> [persistent-actors-cassandra-journal.default-dispatcher-5] >> [akka://persistent-actors/system/cassandra-journal] Failed to connect to >> Cassandra and initialize. It will be retried on demand. Caused by: line >> 2:13 no viable alternative at input 'MATERIALIZED' ( [CREATE] >> MATERIALIZED...)* >> >> Regards, >> Rajesh >> >> On Tuesday, April 5, 2016 at 10:23:02 AM UTC+5:30, Patrik Nordwall wrote: >>> >>> Could it be something with authentication? >>> >>> tis 5 apr. 2016 kl. 05:41 skrev Madabhattula Rajesh Kumar < >>> [email protected]>: >>> >>>> >>>> >>>> On Monday, April 4, 2016 at 6:29:58 PM UTC+5:30, Madabhattula Rajesh >>>> Kumar wrote: >>>>> >>>>> >>>>> Hi, >>>>> >>>>> I am not able to connect Cassandra journal from Akka Persistence. >>>>> Please find below my application.conf and exception details. >>>>> >>>>> Could you please help me to resolve this issue. >>>>> >>>>> akka { >>>>> persistence { >>>>> journal.plugin="cassandra-journal" >>>>> snapshot-store.plugin="cassandra-snapshot-store" >>>>> } >>>>> } >>>>> >>>>> cassandra-journal { >>>>> class="akka.persistence.cassandra.journal.CassandraJournal" >>>>> contact-points = [“127.0.0.1”] >>>>> port = 9042 >>>>> keyspace = “akkajournal” >>>>> table = "journal" >>>>> keyspace-autocreate = true >>>>> >>>>> authentication { >>>>> username = "cassandra" >>>>> password = "cassandra" >>>>> } >>>>> } >>>>> >>>>> cassandra-snapshot-store { >>>>> class = "akka.persistence.cassandra.snapshot.CassandraSnapshotStore" >>>>> contact-points = [“127.0.0.1”] >>>>> port = 9042 >>>>> keyspace = “akkasnapshot” >>>>> table = "snapshots" >>>>> keyspace-autocreate = true >>>>> >>>>> authentication { >>>>> username = "cassandra" >>>>> password = "cassandra" >>>>> } >>>>> } >>>>> >>>>> >>>>> >>>>> *Exception :-*SLF4J: Failed to load class >>>>> "org.slf4j.impl.StaticLoggerBinder". >>>>> SLF4J: Defaulting to no-operation (NOP) logger implementation >>>>> SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for >>>>> further details. >>>>> [INFO] [04/04/2016 18:25:18.760] >>>>> [persistent-actors-akka.actor.default-dispatcher-3] >>>>> [akka://persistent-actors/user/$a] Message >>>>> [com.akka.persistence.Counter$Cmd] from >>>>> Actor[akka://persistent-actors/deadLetters] to >>>>> Actor[akka://persistent-actors/user/$a#1288992689] was not delivered. [1] >>>>> dead letters encountered. This logging can be turned off or adjusted with >>>>> configuration settings 'akka.log-dead-letters' and >>>>> 'akka.log-dead-letters-during-shutdown'. >>>>> [INFO] [04/04/2016 18:25:18.760] >>>>> [persistent-actors-akka.actor.default-dispatcher-3] >>>>> [akka://persistent-actors/user/$a] Message >>>>> [com.akka.persistence.Counter$Cmd] from >>>>> Actor[akka://persistent-actors/deadLetters] to >>>>> Actor[akka://persistent-actors/user/$a#1288992689] was not delivered. [2] >>>>> dead letters encountered. This logging can be turned off or adjusted with >>>>> configuration settings 'akka.log-dead-letters' and >>>>> 'akka.log-dead-letters-during-shutdown'. >>>>> [INFO] [04/04/2016 18:25:18.761] >>>>> [persistent-actors-akka.actor.default-dispatcher-3] >>>>> [akka://persistent-actors/user/$a] Message >>>>> [com.akka.persistence.Counter$Cmd] from >>>>> Actor[akka://persistent-actors/deadLetters] to >>>>> Actor[akka://persistent-actors/user/$a#1288992689] was not delivered. [3] >>>>> dead letters encountered. This logging can be turned off or adjusted with >>>>> configuration settings 'akka.log-dead-letters' and >>>>> 'akka.log-dead-letters-during-shutdown'. >>>>> [INFO] [04/04/2016 18:25:18.761] >>>>> [persistent-actors-akka.actor.default-dispatcher-3] >>>>> [akka://persistent-actors/user/$a] Message [java.lang.String] from >>>>> Actor[akka://persistent-actors/deadLetters] to >>>>> Actor[akka://persistent-actors/user/$a#1288992689] was not delivered. [4] >>>>> dead letters encountered. This logging can be turned off or adjusted with >>>>> configuration settings 'akka.log-dead-letters' and >>>>> 'akka.log-dead-letters-during-shutdown'. >>>>> [WARN] [04/04/2016 18:25:21.275] >>>>> [persistent-actors-cassandra-journal.default-dispatcher-5] >>>>> [akka://persistent-actors/system/cassandra-journal] Failed to connect to >>>>> Cassandra and initialize. It will be retried on demand. Caused by: All >>>>> host(s) tried for query failed (tried: “127.0.0.1”:9042 >>>>> (com.datastax.driver.core.exceptions.TransportException: [null] Cannot >>>>> connect)) >>>>> [WARN] [04/04/2016 18:25:24.317] >>>>> [persistent-actors-cassandra-snapshot-store.default-dispatcher-6] >>>>> [akka://persistent-actors/system/cassandra-snapshot-store] Failed to >>>>> initialize. It will be retried. Caused by: All host(s) tried for query >>>>> failed (tried: “127.0.0.1”:9042 >>>>> (com.datastax.driver.core.exceptions.TransportException: [null] Cannot >>>>> connect)) >>>>> >>>>> Regards, >>>>> Rajesh >>>>> >>>> -- >>>> >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>> >>>>>>>>>> Check the FAQ: >>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>> >>>>>>>>>> Search the archives: >>>> https://groups.google.com/group/akka-user >>>> --- >>>> You received this message because you are subscribed to the Google >>>> Groups "Akka User List" group. >>>> To unsubscribe from this group and stop receiving emails from it, send >>>> an email to [email protected]. >>>> To post to this group, send email to [email protected]. >>>> Visit this group at https://groups.google.com/group/akka-user. >>>> For more options, visit https://groups.google.com/d/optout. >>>> >>> -- >> >>>>>>>>>> Read the docs: http://akka.io/docs/ >> >>>>>>>>>> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user >> --- >> You received this message because you are subscribed to the Google Groups >> "Akka User List" group. >> To unsubscribe from this group and stop receiving emails from it, send an >> email to [email protected] <javascript:>. >> To post to this group, send email to [email protected] >> <javascript:>. >> Visit this group at https://groups.google.com/group/akka-user. >> For more options, visit https://groups.google.com/d/optout. >> > > > > -- > > Patrik Nordwall > Akka Tech Lead > Lightbend <http://www.lightbend.com/> - Reactive apps on the JVM > Twitter: @patriknw > > -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
