[akka-user] akka-cluster - generic failure detector configuration(S)

Hi hAkkers, >From the generic configuration : http://doc.akka.io/docs/akka/current/general/configuration.html I don't really get the differences between the akka.cluster.failure-detector and akka.remote.*-failure-detector : *akka* { [...] *cluster* { # Settings for the Phi accrual

Re: [akka-user] Streaming protobuf objects

Glad it worked out well for you! You'll want to put ` private var tail = ByteString.empty` inside the creation of th GraphStageLogic (otherwise your stage does not rematerialize properly) On Thu, Dec 29, 2016 at 11:10 AM, Leopoldo Müller wrote: > Kyrylo, > > As

[akka-user] Re: [DesignProposal] AKKA cluster in Docker Swarm Environment

Hi, You are welcome! You can use https://github.com/hseeberger/constructr together with https://github.com/typesafehub/constructr-zookeeper to initialize Akka cluster using Zookeeper. Cheers, Rafał -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ:

Re: [akka-user] How to decline a particular SnapshotOffer on recovery?

Hi Konrad, Thanks for answering so fast. I'm not sure, I'm looking for rejecting snapshots. I would like to say I'm looking for programmatic way to migrate an application from one format of snapshots to another and I know prefect way how to do that by hands - just to remove actor's snapshots

[akka-user] Re: [DesignProposal] AKKA cluster in Docker Swarm Environment

Hello Thanks for detailed explanation. I assume we will proceed to distributed lock as you've suggested. One last question, do you think Zookeeper can play this role well ? Or we should consider only Consul / Etcd ? We're using Kafka internally, so we already having Zookeeper in place.

Re: [akka-user] How to decline a particular SnapshotOffer on recovery?

There is no way to "reject but try a different snapshot". The offered snapshot is the latest one matching the criterium, and you either use it or not - "ignoring it". There's no "yeah not that one but another one". How would the lib know what you're looking for? Keep offering all snapshots you

Re: [akka-user] Streaming protobuf objects

Kyrylo, As suggested by √ I implemented the GraphStage, seems to be working so far. import com.google.protobuf.Parser import akka.actor._ import akka.stream._ import akka.stream.scaladsl._ import akka.stream.stage._ import akka.util._ import scala.collection.JavaConverters._ import

Re: [akka-user] how to enable secure tcp socket connection on server side in Akka

Thanks Rafał, Sure i'll go through Akka Stream... On Wednesday, 28 December 2016 22:04:21 UTC+5:30, Rafał Krzewski wrote: > > Gaurav, as Roland wrote above, you cannot just "enable it" in current > version of Akka. You need to combine a few components provided by > akka-streams module to create