Re: [akka-user] How akka cluster become network partition

Network is network. Does not matter if something is close or far. This applies to all distributed systems or databases. Just some prefer to not tallboy about it and then you notice once it's too late and you're screwed ;-) In All we prefer to be upfront and honest about those things. As Patrik lin

Re: [akka-user] How akka cluster become network partition

Does it happen if all servers are inside a LAN? -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search the archives: https://groups.google.com/group/akka-user --- You receiv

Re: [akka-user] Can any actor send message to any other actor?

Hmm. I suspect I would handle a problem like this architecturally, rather than at the individual Actor level. Remember that you don't usually have Actors connecting to each other by name -- instead, Actors usually provide ActorRefs to other Actors. So I would probably have each service provide s

Re: [akka-user] Can any actor send message to any other actor?

Thanks Justin. I also have the same feeling that this is not the right way. My idea was to implement micro services but instead of having standalone HTTP servers for each service I was thinking to have actor system for each service and join them together in a single Akka cluster. To be more spe

Re: [akka-user] Can any actor send message to any other actor?

What's the underlying need here? I can't recall ever seeing anyone do something like this, and it's fairly counter to the general architecture of Akka. I suspect it's impossible in the general case. (Note that custom mailboxes are always a dicey proposition, and usually indicate that you're tryi

Re: [akka-user] Akka Routing question

This is more or less exactly the way that Akka Cluster Sharding works -- I strongly recommend reading the documentation for that. On Thu, Mar 16, 2017 at 6:08 AM, kant kodali wrote: > Hi All, > > I have a stream of JSON encoded messages and I want to distribute them to > group of actors or actor

Re: [akka-user] Re: Cassandra Time Stamp Problem and How Akka can help?

Look at it this way -- typically, you're generating events about some *thing*, which corresponds to the key you're using in Cassandra. That's the "entity" I'm talking about, and typically it would have a single Actor in Akka, to which all events are being sent. That Actor mediates all the Cassand

Re: [akka-user] Spark Streaming using Kafka as a source and Akka with kafka ?

Hey, i see but what im trying to do is would be fast to consume from akka with kafka or directly from kafka i'm not trying to compare akka with spark im' trying to compare reactive kafka which is akka with kafka and kafka without akka and all of that using spark streaming hope i clarified what

Re: [akka-user] How akka cluster become network partition

You can read up on the topic in the documentation for the Split Brain Resolver . On Thu, Mar 16, 2017 at 12:18 PM, Viktor Klang wrote: > Disconnect the cable between A and B. Reconnect cable after the

Re: [akka-user] How akka cluster become network partition

Disconnect the cable between A and B. Reconnect cable after the auto-downer has trigger. On Thu, Mar 16, 2017 at 12:08 PM, Dai Yinhua wrote: > Hi team, > > I am aware that akka cluster may be partitioned to 2 clusters with > auto-downing. > But I can't understand how does it happen? > If node A

[akka-user] How akka cluster become network partition

Hi team, I am aware that akka cluster may be partitioned to 2 clusters with auto-downing. But I can't understand how does it happen? If node A is performing a long GC? And then node A become unreachable, after a while, node A is marked as down, why the cluster is partitioned in this case? Can

[akka-user] Akka Routing question

Hi All, I have a stream of JSON encoded messages and I want to distribute them to group of actors or actor systems based on the field inside a message so say more like hash(key)->Actor but when the Actor dies I want to be able to hash the key to a different Actor that are available but at any g

Re: [akka-user] Re: AKKA HTTP: Is this a valid use of Route.seal?

On 15/03/2017 16:26, 'Johannes Rudolph' via Akka User List wrote: yes, that's a valid use case. The route tree is usually traversed completely until a Route matches. But if you know that the search can be cut short, then `seal` is definitely a good solution. That's exactly the case here - once

Re: [akka-user] Spark Streaming using Kafka as a source and Akka with kafka ?

Use this: https://github.com/akka/reactive-kafka Also, please note that Spark and Akka are not really directly competing... Think about it this way: Can you build an HTTP server with Spark Streaming? Nope. Can you do that with Akka Streams? Yes. Does Akka Streams have built in machine learning thi

[akka-user] Akka in OSGi

Hello everyone I am trying to setup Akka within an OSGi environment and followed the documentation [1]. Though, first I was trying to setup a ActorSystem from a Declarative-Service component rather than an Activator, I realized I should

[akka-user] Can any actor send message to any other actor?

Here is my original unanswered SO question: http://stackoverflow.com/questions/42773328/how-to-isolate-akka-actor Is it possible to protect some actors within a single actor system from other actors? Is it actually a good idea at all? I can imagine to implement a custom mailbox which accepts onl

[akka-user] Spark Streaming using Kafka as a source and Akka with kafka ?

hey there, what i'm trying to do is compare Spark Streaming using Kafka as a source and Akka with kafka i managed to link Spark Streaming with kafka using DirectStream, but im stuck when it comes to spark streaming with akka and kafka i don't understand how to make that connection thanks in adv

[akka-user] Suspending akka stream for a predefined time and then start again.

Hello all, I have a application which reads a stream of "request" messages, process them and makes API calls to Zendesk. Zendesk has a limit of 10 api call/second. And if you hit the rate limit by any change then you will have to wait for a specific interval of time which will be returned in