How to use external cassandra from my lagom application -could not find cassandra contact points

[jayaram]

Hi,

I am trying to run lagom sbt project but, i got struck at Cassandra external connection (could not find cassandra contact points)


Error message:

2018-01-24T13:28:13.232Z [error] akka.cluster.sharding.PersistentShardCoordinator [sourceThread=orderservice-akka.actor.default-dispatcher-4, akkaTimestamp=13:28:13.232UTC, akkaSource=akka.tcp://orders...@orderservice-0.orderservice.staging.svc.cluster.local:2551/system/sharding/kafkaProducer-order-eventsCoordinator/singleton/coordinator, sourceActorSystem=orderservice] - Persistence failure when replaying events for persistenceId [/sharding/kafkaProducer-order-eventsCoordinator]. Last known sequence number [0]
com.lightbend.lagom.internal.persistence.cassandra.NoContactPointsException: No contact points for [_native._tcp.cassandra.staging.svc.cluster.local]


connection details as follows:

order.cassandra {
  authentication {
    username = "*******"
    password = "*******"
  }
  keyspace = *****
}

cassandra.default {
  ## list the contact points  here
  contact-points = ["cassandra.mydomain.com"]
  ## override Lagom’s ServiceLocator-based ConfigSessionProvider
  session-provider = akka.persistence.cassandra.ConfigSessionProvider
}


Please help me with this issue.

[Tim Moore]

Hi Jayaram,

I think your configuration is wrong (or incomplete). Check the documentation again, you'll see that you need to apply the "cassandra.default" properties to the journal, snapshot store and read-side configuration:

cassandra.default {
  ## list the contact points  here

  contact-points = ["10.0.1.71", "23.51.143.11"]

  ## override Lagom’s ServiceLocator-based ConfigSessionProvider
  session-provider = akka.persistence.cassandra.ConfigSessionProvider
}

cassandra-journal {
  contact-points = ${cassandra.default.contact-points}
  session-provider = ${cassandra.default.session-provider}
}

cassandra-snapshot-store {
  contact-points = ${cassandra.default.contact-points}
  session-provider = ${cassandra.default.session-provider}
}

lagom.persistence.read-side.cassandra {
  contact-points = ${cassandra.default.contact-points}
  session-provider = ${cassandra.default.session-provider}
}

Best,

Tim

On Thu, Jan 25, 2018 at 12:16 AM, jayaram <openworld...@gmail.com> wrote:

Hi,

I am trying to run lagom sbt project but, i got struck at Cassandra external connection (could not find cassandra contact points)


Error message:

2018-01-24T13:28:13.232Z [error] akka.cluster.sharding.PersistentShardCoordinator [sourceThread=orderservice-akka.actor.default-dispatcher-4, akkaTimestamp=13:28:13.232UTC, akkaSource=akka.tcp://orderservice@orderservice-0.orderservice.staging.svc.cluster.local:2551/system/sharding/kafkaProducer-order-eventsCoordinator/singleton/coordinator, sourceActorSystem=orderservice] - Persistence failure when replaying events for persistenceId [/sharding/kafkaProducer-order-eventsCoordinator]. Last known sequence number [0]

com.lightbend.lagom.internal.persistence.cassandra.NoContactPointsException: No contact points for [_native._tcp.cassandra.staging.svc.cluster.local]


connection details as follows:

order.cassandra {
  authentication {
    username = "*******"
    password = "*******"
  }
  keyspace = *****
}

cassandra.default {
  ## list the contact points  here
  contact-points = ["cassandra.mydomain.com"]
  ## override Lagom’s ServiceLocator-based ConfigSessionProvider
  session-provider = akka.persistence.cassandra.ConfigSessionProvider
}


Please help me with this issue.

--
You received this message because you are subscribed to the Google Groups "Lagom Framework Users" group.
To unsubscribe from this group and stop receiving emails from it, send an email to lagom-framework+unsubscribe@googlegroups.com.
To post to this group, send email to lagom-framework@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/lagom-framework/0f5fc1dc-467e-4353-943e-107371c9c53e%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

--

Tim Moore

Lagom Tech Lead, Lightbend, Inc.

tim....@lightbend.com
+61 420 981 589
Skype: timothy.m.moore

[jayaram]

Hi Tim,

Thanks for the reply its working fine for external cassandra,

But while deploying lagom setup in kubernetes we are facing issue with sharding


Error message for sharding:

2018-01-29T09:17:44.543Z [error] akka.cluster.sharding.

PersistentShardCoordinator [sourceThread=orderservice-akka.actor.default-dispatcher-2, akkaTimestamp=06:17:44.538UTC, akkaSource=akka.tcp://orderservice@orderservice-0.orderservice.staging.svc.cluster.local:2551/system/sharding/OrderEntityCoordinator/singleton/coordinator, sourceActorSystem=orderservice] - Exception in receiveRecover when replaying event type [akka.cluster.sharding.ShardCoordinator$Internal$ShardHomeAllocated] with sequence number [232] for persistenceId [/sharding/OrderEntityCoordinator].
java.lang.IllegalArgumentException: requirement failed: Region Actor[akka.tcp://order-impl-appli...@127.0.0.1:33024/system/sharding/OrderEntity#192003135] not registered: State(Map(),Map(Actor[akka.tcp://order-impl-application@127.0.0.1:44850/system/sharding/OrderEntity#320305288] -&gt; Vector()),Set(),Set(),false)

Please help me out with this issue.

On Wednesday, January 24, 2018 at 7:16:41 PM UTC+5:30, jayaram wrote:

Hi,

I am trying to run lagom sbt project but, i got struck at Cassandra external connection (could not find cassandra contact points)


Error message:

2018-01-24T13:28:13.232Z [error] akka.cluster.sharding.PersistentShardCoordinator [sourceThread=orderservice-akka.actor.default-dispatcher-4, akkaTimestamp=13:28:13.232UTC, akkaSource=akka.tcp://orderservice@orderservice-0.orderservice.staging.svc.cluster.local:2551/system/sharding/kafkaProducer-order-eventsCoordinator/singleton/coordinator, sourceActorSystem=orderservice] - Persistence failure when replaying events for persistenceId [/sharding/kafkaProducer-order-eventsCoordinator]. Last known sequence number [0]

[Kiran Dhanireddy]

Tim ,Jayaram

Did you find a solution for this issue ?

-Kiran