I have a use case which is million clients data processed by individual actor.And all the actors created on across multiple nodes and formed as a cluster.
When i receive a message i have to send it to the particular actor in the cluster which is responsible for.How can i map to that actor with AKKA cluster.I don't want it to send to other actors.
Can this use case achievable With Akka - Cluster?
How failure handling will happen here?
I cant understand what cluster singleton is,saying in doc that it will only created on oldest node. In my case i only want all million actors as singleton.
How particular actor in cluster mapped with message?
How can i create actors like this in cluster?
How to handle million individual actors with AKKA Cluster setup?
368 Views Asked by Arun At
1
There are 1 best solutions below
Related Questions in AKKA
- Akka-persistence, tagging past event
- how to migate a Akka cluster without stopping service
- Await.result always hangs/timeout and never returns result (Scala - Akka actors)
- Can we create akka actor from the context of shard actor?
- Optimizing CPU Utilization and Throughput in Akka / Pekko Streams on HTTP
- Handling of WebSocket Client Messages in Play Framework
- akka PubSub not working across distributed system
- Handling WebSocket Connections in Play Framework
- Propagating exception to root actor
- akka stream merge data from multiple replicas system
- akka.presistance.postgresql too many clients already
- Akka Streams: How to construct a Source of Sources with GraphDSL?
- Skip flow on failure akka streams
- How to regulate the speed between actors in java?
- Keep ordering by merging multiple slow sources in akka streams
Related Questions in AKKA.NET
- akka.presistance.postgresql too many clients already
- Troubleshooting Akka.NET Streams: Messages Not Reaching Remote Sink Actor in Source-Sink Pattern
- How to clear the mailbox when restarting an actor in Akka.NET
- Add Azure App Service to a Cluster running in two Azure VMs using Akka.Net
- Akka.net .NET Core configuration
- How to access OfferAsync method of Source.Queue when using Akka.Net Graphs?
- Akka.Management DiscoveryMethod.Config
- Akka.net - remember entities issue
- How to get reference to remote ProducerController in Akka.NET's Akka.Delivery?
- Akka.net Executing long-running actions inside an actor’s Receive method
- Akka .Net Serilog Configuration semantic logging won't work
- AKKA.NET Architecture Best practices
- Akka.Hosting - Dependancy Injection in Actor parameter
- Can an Akka.net node hosted within a container participate in a cluster outside of the container host?
- How to Implement Actor.Ask to Control the flow of data at a certain rate
Related Questions in AKKA-CLUSTER
- how to migate a Akka cluster without stopping service
- Can we create akka actor from the context of shard actor?
- akka-cluster: unable to get rid of actors from scaled down node
- akka-cluster: actor not picking up a job
- AtMost Once Message Delivery in Actor Cluster Sharding Entity Actor
- seed nodes not able to join akka cluster
- Akka ask doesn't seem to send a message to the actor
- Actor Cluster with WeaklyUp Members making the cluster too slow to respond
- Akka cluster behavior after bringing down one node
- Wrong protocol for root guardian when changing from akka to pekko
- Issue with pruning in Remember entities of Actor Cluster Sharding
- Can't receive the messag in Akka Cluster
- Akka.Management DiscoveryMethod.Config
- Custom dispatcher for specific sharded actor
- Akka cluster bootstrap in Docker Compose
Related Questions in AKKA-REMOTE-ACTOR
- AtMost Once Message Delivery in Actor Cluster Sharding Entity Actor
- Actor Cluster with WeaklyUp Members making the cluster too slow to respond
- Issue with pruning in Remember entities of Actor Cluster Sharding
- How can get the count of Active live actors?
- Trouble Connecting to Custom Akka.NET Transport
- Which dispatcher configuration in AKKA is efficient for more no of actor processing in parallel?
- How can we send a message from an actor system outside the Akka Cluster
- Akka Cluster basic clarifications about creating actors dynamically
- How to create an actor in Akka cluster dynamically
- Any blogs,articals or docs to learn AKKA Remote internals?
- How to use Cluster singlton or Cluster sharding in Akka-Cluster for million individual Actors?
- How to handle million individual actors with AKKA Cluster setup?
- Nested, Remote, Round-Robin Pool in Akka.NET
- SerializationException while sending Record between remote actors using Akka.FSharp
- No response from remote for outbound association. Associate timed out after [15000 ms]
Related Questions in AKKA-DISPATCHER
- Issue with pruning in Remember entities of Actor Cluster Sharding
- Make Akka guardian actor use custom dispatcher
- Which dispatcher configuration in AKKA is efficient for more no of actor processing in parallel?
- How to handle million individual actors with AKKA Cluster setup?
- Why the actorSystem is not creating the actor to run with custom dispatcher
- When to use more instances of same Akka actor?
- Actor message allocation to dispatcher thread
- Akka Dispatcher Thread creation
- How to configure dispatcher correctly in asp.net core akka
- Why Akka shutdowns dispatcher, when there is no tasks?
- What does the "throughput-deadline-time" configuration option do?
- Why are Futures within Futures running sequentially when started on Akka Dispatcher
- How do I control the run-time execution of an actor system in Akka?
- Akka Streams Reactive Kafka - OutOfMemoryError under high load
- How to create BalancingDispatcher using Akka in Java?
Trending Questions
- UIImageView Frame Doesn't Reflect Constraints
- Is it possible to use adb commands to click on a view by finding its ID?
- How to create a new web character symbol recognizable by html/javascript?
- Why isn't my CSS3 animation smooth in Google Chrome (but very smooth on other browsers)?
- Heap Gives Page Fault
- Connect ffmpeg to Visual Studio 2008
- Both Object- and ValueAnimator jumps when Duration is set above API LvL 24
- How to avoid default initialization of objects in std::vector?
- second argument of the command line arguments in a format other than char** argv or char* argv[]
- How to improve efficiency of algorithm which generates next lexicographic permutation?
- Navigating to the another actvity app getting crash in android
- How to read the particular message format in android and store in sqlite database?
- Resetting inventory status after order is cancelled
- Efficiently compute powers of X in SSE/AVX
- Insert into an external database using ajax and php : POST 500 (Internal Server Error)
Popular # Hahtags
Popular Questions
- How do I undo the most recent local commits in Git?
- How can I remove a specific item from an array in JavaScript?
- How do I delete a Git branch locally and remotely?
- Find all files containing a specific text (string) on Linux?
- How do I revert a Git repository to a previous commit?
- How do I create an HTML button that acts like a link?
- How do I check out a remote Git branch?
- How do I force "git pull" to overwrite local files?
- How do I list all files of a directory?
- How to check whether a string contains a substring in JavaScript?
- How do I redirect to another webpage?
- How can I iterate over rows in a Pandas DataFrame?
- How do I convert a String to an int in Java?
- Does Python have a string 'contains' substring method?
- How do I check if a string contains a specific word?
Assuming that each actor is responsible for some uniquely identifiable part of state, it sounds like you want to use cluster sharding to balance the actors across the cluster, and route messages by ID.
Note that since the overhead of an actor is fairly small, it's not implausible to host millions of actors on a single node.
See the Akka JVM or Akka.Net docs.