[akka-user] Artery and IPC

Hi there I’m thinking of using Akka cluster in a single machine style scenario (low powered router), so that I can use distributed pub/sub across processes in particular. I see that Aeron supports IPC as a transport, but Akka’s Artery doesn’t appear to be able to utilise it - I could be

Re: [akka-user] Is Akka Streams an FRP Solution?

As we know it implements Reactive Streams. Source works as Publisher and Sink works as Consumer Flow as Subscription. It supports back-pressure very well. Akka uses Scala as a FP language. It supports most of the FP operations like map, flatMap, filter etc to perform operations on Data Streams.

Re: [akka-user] How to decline a particular SnapshotOffer on recovery?

A thought: On Fri, Oct 27, 2017 at 6:27 AM, Stephen Kennedy wrote: > Sorry to resurrect an old topic, but I am having the exact same conundrum. > > My particular use case is: > - I have a persistent actor that is similar to a FSM with a "state" enum > that represents its

Re: [akka-user] Is Akka Streams an FRP Solution?

Precisely what do you think FRP means? In my observation, it's a buzzword that is used rather loosely, with a variety of definitions... On Thu, Oct 26, 2017 at 6:40 PM, Rambabu Posa wrote: > Hi > > We know Akka Toolkit is Reactive Solution. Can we also say that Akka >

Re: [akka-user] Need of `onRecoveryCompleted` in akka typed for persistence

On Fri, Oct 27, 2017 at 12:19 PM, Yaroslav Klymko wrote: > Sure, > > But then I won't see the potential problems that during recovery for > instance we are renaming missing entry. > With ongoing development and more complicated data structures, when you > might have tens

Re: [akka-user] How to decline a particular SnapshotOffer on recovery?

Sorry to resurrect an old topic, but I am having the exact same conundrum. My particular use case is: - I have a persistent actor that is similar to a FSM with a "state" enum that represents its current state - Some additional business logic has lead to me wanting to inspect the previous

Re: [akka-user] Need of `onRecoveryCompleted` in akka typed for persistence

Sure, But then I won't see the potential problems that during recovery for instance we are renaming missing entry. With ongoing development and more complicated data structures, when you might have tens nesting deep it is becoming crucial to validate recovery against previous versions and to

Re: [akka-user] Need of `onRecoveryCompleted` in akka typed for persistence

You can rewrite that to: case class State(entries: Map[String, Entry]) { def applyEvent(event: Event): State = { event match { case Event.EntryAdded(id, name) => copy(entries + (id -> Entry(name))) case Event.EntryRenamed(id, newName) =>

Re: [akka-user] Need of `onRecoveryCompleted` in akka typed for persistence

Hi Patrik, here is very simplified example: object Example { case class Entry(name: String) case class State(entries: Map[String, Entry]) { def applyEvent(event: Event): Either[String, State] = { event match { case Event.EntryAdded(id, name) => entries.get(id)

Re: [akka-user] Need of `onRecoveryCompleted` in akka typed for persistence

On Fri, Oct 20, 2017 at 5:29 PM, Yaroslav Klymko wrote: > > On Friday, October 20, 2017 at 4:44:35 PM UTC+2, Patrik Nordwall wrote: >> >> >> >> On Thu, Oct 19, 2017 at 2:52 PM, Yaroslav Klymko >> wrote: >> >>> >>> >>> >>> On Thursday, October 19, 2017 at

Re: [akka-user] Timer of GroupedWithin (akka-stream-kafka) does not seem to be working

Apologies. Taking note for future. shall I delete this post? On Friday, 27 October 2017 14:16:30 UTC+5:30, Konrad Malawski wrote: > > Please report in one space at the same time. > This was already reported on the issue tracker by yourself. > > This is to avoid wasting cycles and time. Thanks. >

Re: [akka-user] Timer of GroupedWithin (akka-stream-kafka) does not seem to be working

Please report in one space at the same time. This was already reported on the issue tracker by yourself. This is to avoid wasting cycles and time. Thanks. -- Cheers, Konrad 'ktoso ' Malawski Akka @ Lightbend On October 27, 2017 at

[akka-user] Timer of GroupedWithin (akka-stream-kafka) does not seem to be working

Timer of GroupedWithin does not seem to be working. In this example, I am not getting any messages even after expiry of duration (10 seconds) even though 7 items are available in Kafka. If I produce 3 more items, then I am getting the entire desired batch (10 items). Please see the snippet