Perhaps something like this in order to get your FiniteDuration:
Duration.ofMillis(
ChronoUnit.MILLIS.between(
ZonedDateTime.parse("2007-12-03T10:15:30+01:00[Europe/Paris]"),
ZonedDateTime.now
)
)
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
Hi there,
I've got a situation where I observe a postStop being called within my
custom GraphStage prior to when I'd expect. I'm sure Akka is doing the
right thing but, what's the best way to debug what is causing the postStop?
My understanding is that the input and output connections should
Hello.
Maybe someone also have a similar case or maybe it could be good start to
extend akka functionality with pull request?..
The case is: I'm using PersistentFSM and I'd like my actor would stay at
last/current state let's say till next Tuesday or till beginning of next
hour etc. Luckily
So the only way I was able to successfully identify the suspicious code was
to route a percentage of my production traffic to a stubbed route that I
incrementally added back pieces of our implementation into. What I found
was that we started getting spikes when the
Hi Serhi
Yes you're right the current partition key only works if you have a
smallish number (10ks) of events per tag per day.
The main messages table works like #2 for persistence ids but it all
happens internally via the partition_nr column rather than the user having
to do it.
We're
Hello
eventsByTag in the CassandraReadJournal uses a materialized view to read
the events. Currently materialized view is created by
CREATE MATERIALIZED VIEW IF NOT EXISTS $eventsByTagViewName$tagId AS
SELECT tag$tagId, timebucket, timestamp, persistence_id, partition_nr,
sequence_nr,
Hi all,
I have the task of maintaining a year old akka app using remoting. The app
consists of two services (lets say frontend and backend) communicating
using remoting with protobuf serialization.
Both the services are currently running as a service in docker swarm. When
there is only 1
My thought was that maybe you could achieve what you want by composing it
with existing stages, perhaps zipWithIndex+map index to key/ or use
stateFulMapConcat to decide when to change the key, and then groupBy into a
lazy sink. Can't say I'm sure that will solve your problem, but may be
worth
