Re: [akka-user] Akka Cluster Failing for Huge Data File

Is it because I am running application on single physical machine , the application is taking more time the process? On Tuesday, May 16, 2017 at 9:22:28 AM UTC+5:30, Kunal Ghosh wrote: > > Hey Patrik, Thanks for the help !! > your solution worked ! > Now when I run my application in non

[akka-user] Lightbend Monitoring and jmDNS issues

I was just experimenting with the Lightbend Monitoring tools and following the Getting Started instructions. The target application registers actors with a *location service*, currently based on multicast DNS

Re: [akka-user] [akka-cluster] Sharding, extractShardId and cluster resizing

Wow, so comprehensive. Thank you very much. вівторок, 16 травня 2017 р. 18:46:10 UTC+3 користувач Justin du coeur написав: > > On Tue, May 16, 2017 at 11:38 AM, Evgeny Shepelyuk > wrote: > >> My current worrying question is about how to properly build extractShardId >>

Re: [akka-user] [akka-streams] StreamConverters.fromOutputStream(..) stops processing messages

Thanks for the tip! I've found the culpit -- threads were not blocked, they all were waiting for read from corresponding input streams, separate dispatcher for intput and output streams resolves this problem. Still, I'm not comfortable with so many thread blocking on read, so I'll try to

Re: [akka-user] Re: akka kafka stream parallel processing

hi, In the below code, my outmsg from the result, in one case, i need to flat it to multiple output messages, i am stuck as where/how can i do it, really appreciate if someone can help. Thanks Shannon Source,

Re: [akka-user] [akka-cluster] Sharding, extractShardId and cluster resizing

On Tue, May 16, 2017 at 5:46 PM, Justin du coeur wrote: > On Tue, May 16, 2017 at 11:38 AM, Evgeny Shepelyuk > wrote: > >> My current worrying question is about how to properly build extractShardId >> function. >> According to the docs this function

[akka-user] [akka-cluster] Sharding, extractShardId and cluster resizing

Hello I'm implementing sharding solution on top of AKKA cluster running in Docker Swarm. The requirement we'd like to achieve is to be able to scale our sharded services. It's easily achieved with docker swarm, so we can have as many instances of services as we want. Thanks to ConstructR

Re: [akka-user] [akka-streams] StreamConverters.fromOutputStream(..) stops processing messages

It could be that all of the threads are blocked in the default-blocking-io-dispatcher Make a thread dump and take a look if that is the case. On Mon, May 15, 2017 at 8:17 PM Alexey Shuksto wrote: > Hello hAkkers, > > Our app spawns multiple external processes (via >