494 questions
0
votes
0
answers
38
views
Better way to integrate Kafka with Akka Cluster Sharding
We have Kafka as the bus and Akka Cluster Sharding as the application distributed cluster. So we need to consume data from Kafka and process them in Akka Cluster.
For a now we implement separate ...
0
votes
1
answer
40
views
Does akka coexistence support distributed pub-sub across nodes that are a mixed of akka classic and akka typed?
We have an akka 2.6 cluster written in java and there are two roles (named 'manager' and 'executor') in the cluster with distinct functions. Currently it is all akka classic.
We want to move to akka ...
0
votes
1
answer
53
views
Akka Typed Actor Discovery
I am in the process of learning Akka remoting and clustering. I am not getting the expected behavior when I am trying to send a message to a remote Actor.
Remote Actor deployed on localhost:2552
...
-1
votes
1
answer
101
views
How to read the journal at a specific point in time with akka event sourcing
I am currently trying to implement a git like storage with akka event sourcing in combination with CQRS. The write path is implemented via an EventSourcedBehavior actor (will refer to it as ...
0
votes
1
answer
146
views
How to stub Cluster Sharding to test Akka HTTP Routes
While trying to setup a routes test for a sharding cluster in Akka I always get "system" is null:
Cannot invoke "akka.actor.ClassicActorSystemProvider.classicSystem()" because &...
0
votes
1
answer
173
views
Akka cluster handover during rolling updates in kubernetes
I have been trying to deploy an akka-cluster in kubernetes with the recommended rollingUpdate plus cluster app-version for a smooth deployment with minimum downtime. However the handover process is ...
0
votes
1
answer
66
views
how to migate a Akka cluster without stopping service
I started a ODL(opendaylight) cluster with the following akka config:
enter image description here
So, the nodes(11.128.83.43, 11.128.83.33, 11.128.83.32) make up a cluster, 11.128.83.43 is member-1, ...
0
votes
1
answer
42
views
Can we create akka actor from the context of shard actor?
I want to understand can we create an actor from the context of shard actor(from inside shard actor) and delegate some work to it?
If i create an actor from shard actor ,are there any limitations ?
...
0
votes
1
answer
60
views
akka-cluster: unable to get rid of actors from scaled down node
I face an issue using akka cluster.
System setup: 2 nodes, each having 2 instances of a worker actor. All these actors(4 in total) are tracked by a singleton actor in the application.
Issue is that ...
0
votes
0
answers
158
views
akka-cluster: actor not picking up a job
I am using akka cluster for actor distribution, and struggling with an issue.
In my application, I have an actor, say 'engine' which processes a job. From configuration, I can set how many instances
...
1
vote
1
answer
89
views
AtMost Once Message Delivery in Actor Cluster Sharding Entity Actor
Is There Any way to Achieve AT-MOST once message delivery in Actor Cluster Sharding.
I'm Using Actor Cluster Sharding for a usecase where i have Set of Cluster Nodes and Set of Proxy Nodes.
From proxy ...
1
vote
1
answer
229
views
seed nodes not able to join akka cluster
I am trying to bootstrap an akka cluster for my akka typed actorsystem, but the seed node fails to join the cluster for some reason. I get this error
Cluster Node [akka://[email protected]:25520] - ...
0
votes
0
answers
116
views
Akka ask doesn't seem to send a message to the actor
I am trying to create a simple simulation using Akka Cluster + Akka Http. The idea is that the frontend is going to process incoming http get and post requests. The server is launched after the ...
1
vote
1
answer
87
views
Actor Cluster with WeaklyUp Members making the cluster too slow to respond
Need some clarification about Auto Downing & WeaklyUp Members.
We have 5 Nodes cluster.
2 Nodes Cluster Node
3 Node Proxy node(Shard Region proxy).
We send data from proxy to Cluster Node.Before ...
0
votes
0
answers
81
views
Akka cluster behavior after bringing down one node
I'm using Akka 2.6 and seeing some weird behavior
Setup:
Node0
Node1
Node2
On starting the cluster, I can see the welcome message from
Node0-Node1
Node0-Node2
When I gave some work, it was getting ...