[akka-user] Akka Persistence With Cassandra

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
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.

Dear hakkers, we proudly present two additions to the Akka github family: akka-persistence-cassandra and akka-persistence-dynamodb . Both projects have their roots in the Eventsourced project by Martin Krasser, the predecessor for Akka Persistence. In the case of the DynamoDB plugin Scott Clasen did the initial development up to Akka 2.3.3 (thanks!) and with some help from Paul Cleary we upgraded
I am new to AKKA. I did some researches but don't find the answer I wanted. Maybe I don't know what keywords to search for. The scenario is we are trying to use akka persistence cassandra plugin to save the incoming messages to cassandra in case the Actor is stopped or the server is down, the unprocessed message can be recovered and being process again. I've extended from AbstractPersistentActorWithAtLeastOnceDelivery
Dear group I am quite new to Akka persistence, and very new to Cassandra. The combination is working fine, however, except one problem: Mass deletions and compaction. It seems, if I understood Cassandra correctly, that my usage is an anti-pattern (*). I have actors that read a lot of messages, and persist a hash of them (for duplicate detection). Every hour I take a snapshot, and deletes
Hello ALL, I am on my wits end to get this issue figured out by myself. Any suggestion would be appreciated. The followings are information for what I am using: * AKKA 2.4.2* * Cassendra 2.6* * Akka-persistence-cassandra 0.11* applicaton.conf akka.persistence.journal.plugin = "cassandra-journal" akka.persistence.snapshot-store.plugin = "cassandra-snapshot-store
Team, I working on a app built on top of akka persistence and java. I am using cassandra plugin i.e. akka-persistence-cassandra_2.10-0.3.4.jar. Its from repository http://dl.bintray.com/krasserm/maven/.  I am facing below exception. Kindly let me know, what is the expected fix. Uncaught error from thread [rce-reference-java-akka.persistence.dispatchers.default-replay-dispatcher-25] shutting
Hi all, I'm trying to use Akka's Cassandra integration to save and restore a String (with Akka 0.8.1 and Cassandra 0.6.1). I can't get it to work. When I try, one of two things happens: 1) Everything freezes and I have to kill and restart my IDE. This seems to happen within CassandraStorage.newRef. 2) It works, but fails to save anything. The first I send the HelloWorld message I'll get a
I want to get started with Akka persistence.  Do I need to upgrade to akka 2.4 to be able to use the latest Akka persistence  "com.typesafe.akka" %% "akka-persistence-experimental" % "2.4-SNAPSHOT" OR will it work with akka 2.3.x as well ?  Also, I want to use a Cassandra journal using  https://github.com/krasserm/akka-persistence-cassandra The build.sbt uses akk-persistence-experimental
Hi, I am using the journal plugin for akka persistnce as listed here https://github.com/krasserm/akka-persistence-cassandra/, however I see its mentioned that it works only with cassandra 2.0.3 and higer and we have cassandra in our project configured but of version 1.2.13.2, does that mean we would be unable to use this? Post configuring the journal cassandra based plugin when I start our akka
Hello everyone, I'm starting with Akka Streams and so far everything is going well. However, I have met with a use case that I don't know how to approach. The scenario is a stream with an ActorPublisher as a source that is consuming messages from Kafka and a subscriber as a sink that updates a Cassandra table. Kafka ~> some mapping operations ~> Cassandra The point is that I'd like
Dear group I am trying to implement some integration tests of my system using Stubbed Cassandra (to test what happens when requests time out etc). The problem is that Akka Persistence makes a lot of queries, and it would take a lot of priming for the stubbed Cassandra to behave like the real server. Has anyone of you done this successfully? Or do you integration-test timeouts etc
My team uses akka-persistence 2.3.3 and akka-persistence-cassandra 0.3.1.  Recently, in production, my team observed a View that did not appear to be polling as expected.  The application had been running for about 12 hours (and previously has run for much longer without issue).  Updates to Cassandra did not propagate to the consuming application.  The consumer did not emit any error level logging
Hi All, I am new to akka. I noticed akka 1.0 have akka.persistent.cassandra pacakage to support access to cassandra. But I could not find it on akka1.1 or other package related to cassandra. Does akka 1.1 still support cassandra access? Any advice is appreciated. Thanks
I wanted to try the async Cassandra driver from DataStax, in a Scala/Akka app, so I took a look at the Akka Cassandra Activator template. https://github.com/eigengo/activator-akka-cassandra I copied cassandra.scala from the template (it contains a conversion from ResultSetFuture to a Scala future). Unfortunately that file doesn't compile in my project - the error is: value addListener
I know the akka team is busy and working very hard, but I figured I'd ask, is there a timeline on when the CassandraStorage backend will be able to work with cassandra 0.7.x release series?
Hi All, I am pretty new to Spark and still learning the basics. I want to create RDD's from data that is stored in a Cassandra database. in the org.apache.spark.rdd package there are several classes but didn't find any related to Cassandra. i did stumble across [1] so i assume that it is possible to use Spark with Cassandra. Would be great if someone could point me in the right direction.
Hello All; Please, i have created this table. lastname | age | city | email | firstname Doe | 36 | Beverly Hills | [email protected] | Jane Byrne | 24 | San Diego | [email protected] | Rob Smith | 46 | Sacramento | [email protected] | John So, my question, where this data is saved ? in ./var/lib/cassandra/data ? My end goal
Hi everyone, jsr166x and Cassandra 0.5.0 don't have any POMs in the Akka repository. This doesn't seem to lead to any critical problems, but it causes Maven to search all known repositories (which is a lot for an Akka-based application) which is annoying and slows down the build considerably. If you have this problem, an easy workaround is to place the pom files I have attached to this message
Hi all, How can I integrate Solr with Cassandra. I am using Cassandra as my primary database. I have seen solandra but the project is dead. What are the ways available now. Thanks View this message in context: http://lucene.472066.n3.nabble.com/Using-solr-with-cassandra-tp4226137.html Sent from the Solr - User mailing list archive at Nabble.com.
HI All, I am a Masters student at University of Buffalo. As my masters project I decided to "Analyse the performance of�column-oriented�databases (Titan+Cassandra) with graph database�(Neo4j) for Social Network Graphs." Question / Hypothesis :�Traditional Graph databases should perform better as Social Networks is a typical Graph Database, but why big tech companies are still working with column
Hello! I was hoping some has experiences with both Cassandra and HBase. What are the major differences between Cassandra and HBase? Does HBase have the concept of ColumnFamilies and SuperColumnFamilies like Cassandra? Where in the wiki does it go over designing a data model? thanks!