305 questions
- Bountied 0
- Unanswered
- Frequent
- Score
- Trending
- Week
- Month
- Unanswered (my tags)
0
votes
1
answer
48
views
Proper handling of akka events on rollback
For simplicity, we have ff info:
Command1(name: String)
State1
Event1(name: String)
State2(data1: String, name: String)
I wanted to display the person's gender in State2 and for that to work I need ...
-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
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
132
views
Akka persistence creates new DB connection pool
I have akka microservice, for DB I use config like:
companyname.db {
profile = "slick.jdbc.MySQLProfile$"
db {
driver = "org.mariadb.jdbc.Driver"
url = "jdbc:mysql:...
0
votes
0
answers
79
views
Akka: currentEventsByPersistenceId always returns zero for 'eventEnvelope.timestamp'
I am experimenting with the currentEventsByPersistenceId query from akka-persistence-query to retrieve and process events stored in the messages table. However, I've encountered an issue where the ...
1
vote
1
answer
126
views
In Akka Typed Event Sourcing is it common to use a single db (the same event journal) for multiple typed persistent entities?
Suppose in application office there are two EventSourcedBehavior actors
trait OfficeFridgeCommand
case object OpenFridge extends OfficeFridgeCommand
case object CloseFridge extends OfficeFridgeCommand
...
0
votes
1
answer
141
views
Akka: Events by tag and creation time
I have an application that uses Akka along with Cassandra for Event Sourcing. As part of an API response, I need to show the number of events of a specific type/tag (say UpdateEvent) that happened at ...
-1
votes
1
answer
69
views
How to reuse CqlSession of Akka persistence plugin in Custom serializer
In Akka i'm creating a custom serializer for my app that sometimes go to cassandra database to fetch something.
To do this a repository is created and then is registered via Akka Extension to actor ...
1
vote
2
answers
474
views
Akka 2.7.0 memory leak?
I'm using Akka actor system with version 2.7.0 and we are facing memory leak issue as below:
When the process gets completed, memory is not getting free and below are two potential causes:
enter ...
0
votes
1
answer
155
views
How to test persistent actors with ScalaTest, ZIO and Akka
I have one "use case" that I would like to test. This one returns a zio.IO resulting from a call to an Actor (scala.concurrent.Future). And, I would like to use ScalaTest's AnyWordSpec.
...
0
votes
0
answers
215
views
Akka Durable State Postgres Exception
I am using the Play Framework 2.8.18 and I am trying to use akka's Durable State Feature. This is my implementation so far:
public class CompanyActorTest extends DurableStateBehavior<...
0
votes
1
answer
116
views
Akka-persistence, event propagation from one actor to another
I have one question about akka-persistence and event migration. I do have read the "Schema Evolution for Event Sourced Actors" chapter. However, this does not give an answer to my question.
...
0
votes
1
answer
472
views
Akka CircuitBreaker - Is it possible to find what caused the circuit breaker to trip?
Is it possible to find what caused the circuit breaker to open? Per Akka documentation https://doc.akka.io/api/akka/current/akka/pattern/CircuitBreakerOpenException.html, the default message "...
1
vote
2
answers
85
views
Not able to execute Akka Work pulling java example provided in the akka document
I am interested in understanding the work pull feature in akka. I am trying to create a main method for the example provided that will create and start the producer(ImageWorkManager class in the ...
0
votes
1
answer
134
views
akka projection + akka serialization cause JVM Crash with StackOverFlowError
I am new to Akka Projection + Akka Serialization, I applied official shopping cart 6th tutorial into my own project, and at first shot jvm crashed. I wish to know where should I look into.
Event ...