Actually, I was referring to this
http://doc.akka.io/docs/akka/2.4.12/scala/persistence-query.html#Resumable_projections
We are using Kafka upstream from this. A (persistent) actor A consumes the
Kafka stream. Another persistent actor B uses eventsByTag(A) and runs a
stream with several stages.
Hi Richard,
This is not handled by streams itself as it is a feature that Sources must
support. I think the most common solution people use for this is Kafka.
There is a Streams connector for Kafka:
https://github.com/akka/reactive-kafka
-Endre
On Tue, Nov 15, 2016 at 3:04 AM, Richard Rodseth
Any good examples out there of resumable projections driving non-trivial
streams?
I'm guessing I will have to keep the stream 1-1 and pass the offset all the
way downstream so I can save it at the end?
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
