Re: [akka-user] Example about cluster sharding

Thanks Justin! Unfortunately I forgot to mention that I need a Java example. Do you know some? Best Martin On Thursday, January 5, 2017 at 7:36:01 AM UTC-8, Justin du coeur wrote: > > Hmm -- Querki is large and complex, but it's > heavily based on Cluster Sharding,

[akka-user] Is there anyway to view the content of the journal or snapshot file for leveldb

As the title, I tried to use Keylord to read the content of the .ldb file, but it failed, I would like to know what content is persisted. Thanks. -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

Re: [akka-user] Akka persistent

Hi Patrik, >From Akka documentation, "Note that *Cluster Sharding* is using snapshots, so if you use Cluster Sharding you need to define a snapshot store plugin." So I am wondering if

Re: [akka-user] Code in Akka-HTTP documentation doesn't seem to compile

Gah, yes, clicked on the wrong goddam doc link, sorry for the noise, time to go to bed I think... The continual "{}" nesting in the Scala DSL get's messy pretty quickly... -- Alan Burlison -- -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

Re: [akka-user] Code in Akka-HTTP documentation doesn't seem to compile

Sure `RawHeader.create` exists: https://github.com/akka/akka-http/blob/master/akka-http-core/src/main/java/akka/http/javadsl/model/headers/RawHeader.java#L11 Otherwise we would not have been able to release these docs - they've compiled and validated and only then we release :) You seem to be

[akka-user] Code in Akka-HTTP documentation doesn't seem to compile

From http://doc.akka.io/docs/akka-http/current/java/http/routing-dsl/directives/respond-with-directives/respondWithHeader.html final Route route = path("foo", () -> respondWithHeader(RawHeader.create("Funky-Muppet", "gonzo"), () -> complete("beep"))); That doesn't look like valid syntax

Re: [akka-user] How to call a Future-based test from a Route?

On 02/01/17 21:12, Konrad Malawski wrote: How about sharing in a blog or docs about how to go about building such? I think that'd be very interesting to people who're faced similar questions as you were just a few days ago :) Here's what I ended up with: def authBasicHttp: Directive1[Login]

Re: [akka-user] Consistent Dissasociation, small cluster

Thank you Patrik. As you mentioned might be the case, the added configuration was not adequate to solve the problem. I have followed the advice on the dispatchers documentation page, and set up our actors that have blocking behavior to use either a pinned dispatcher, or in the case of a router

Re: [akka-user] Circuit Breaker timeouts reading persistence from Cassandra

Hi Richard, you gave too little information to be able to anyone help you. If you are getting circuit breaker timeouts most likely Cassandra is under the pressure. Monitor Cassandra health during recovery. If you are using akka sharding maybe you need to tweak akka.cluster.

Re: [akka-user] Example about cluster sharding

For Scala there is also http://www.lightbend.com/activator/template/akka-cluster-sharding-scala but it's not ported to Java. On Thu, Jan 5, 2017 at 4:41 PM, Konrad Malawski < konrad.malaw...@lightbend.com> wrote: > Some time ago we implemented the Reactive Maps sample. > It uses an Akka cluster

Re: [akka-user] Akka persistent

For learning with Cassandra, I also strongly recommend picking up ccm -- it makes it *vastly* easier to run a local Cassandra pseudo-cluster on your machine, and works quite well for akka-persistence-cassandra development and testing. On Thu, Jan 5, 2017 at 9:09

Re: [akka-user] Example about cluster sharding

Some time ago we implemented the Reactive Maps sample. It uses an Akka cluster with sharding, see description here: https://github.com/typesafehub/ReactiveMaps/blob/master/tutorial/index.html Get it using activator: http://www.lightbend.com/activator/template/reactive-maps or just clone the above

Re: [akka-user] Example about cluster sharding

Hmm -- Querki is large and complex, but it's heavily based on Cluster Sharding, and it's all open source , so might be useful to look at as a complex real-world example. Feel free to poke around there and ask me questions. SpaceRouter

[akka-user] Snapshots

I have a PersistentActor which is a read side projection that runs a persistence-query stream. It's only state is an offset, a Long. Protobuf serialization is used for persistence messages. I'm preparing to add snapshotting. The examples show a "snap" message handled by calling saveSnapshot. Am

Re: [akka-user] Akka persistent

snapshots should only be treated as an optimization, so it should not be necessary to load snapshots. shared-leveldb-journal is only intended for testing, but also for that purpose I would recommend using something real such as akka-persistence-cassandra. /Patrik On Thu, Jan 5, 2017 at 9:34 AM,

Re: [akka-user] Akka clusters using cluster client causing quarantined nodes (v2.3.11)

Thanks for sharing great advice, Daniel. I would not change the transport-failure-detector to 1 second. The purpose of this failure detector is to find broken TCP connections and restart them. TCP handles this by itself in most cases. I would guess 1 second could result in a lot of false

Re: [akka-user] Consistent Dissasociation, small cluster

That is an excellent analysis, Jordan. The verbose-heartbeat-logging is useful for exactly this kind of debugging. You need to find why NODE-1 was "paused". You said that you might be doing some blocking activity in your actors. I strongly recommend that you eliminate such blocking or assign a

Re: [akka-user] Consistent Dissasociation, small cluster

Hi Jordan, It looks very related to the issue we are facing, with the difference we are not able to recover from the UNREACHABLE mark, probably because the cluster specs are different : in our scenario we have 3 cluster singletons and we use auto-downing . Cheers, Francesco On 4 January 2017

[akka-user] Re: Emulate Geo Dispersed Actors on Local Machine

Some further information on problem is revealed by this debug data. This shows a transformation of path to the recipient that is the immediate cause of the error. Post Discard DEBUG] [01[/05/2017 04:28:55.557] [community-akka.remote.default-remote-dispatcher-6] [akka.remote.Remoting]

Re: [akka-user] Akka clusters using cluster client causing quarantined nodes (v2.3.11)

In my organisation we had quite a number of problems with Cluster quarantine behaviour both in AWS and on our own local PCs (We launched a cluster of 5 actor systems during test so that tests emulated as closely as possible our intended production environment). What we found was that

[akka-user] Example about cluster sharding

Hi, I am new to Akka and using Akka to write an application which contains many stateful actors. I would like to make all the actors can be either deployed on single node or multiple nodes without changing the actors codes. After reading the manual, I believe the cluster sharding is way to go.

[akka-user] Akka persistent

Hi Guys, I'm learning Akka cluster sharding with shared leveldb plugin. Here is my config: persistence { journal.plugin = "akka.persistence.journal.leveldb-shared" journal.leveldb-shared.store { # DO NOT USE 'native = off' IN PRODUCTION !!! native = off