Re: [akka-user] Using akka.persistence.Reset from Java

Thanks. It'd be helpful to include this information about persistent channels being resettable via the Reset message and via a restart in the documentation on persistent channels (both the overall persistence doc. and the PersistentChannel java doc.). Regarding reset on restart, do you mean wh

Re: [akka-user] What is the best way to integrate kafka and akka

Hey man! So far so good, under load you dont have to worry about the timeout ever happening really. The client is structured as a supervisor actor that is responsible for committing the offsets periodically or after N messages, which spins up a number of child Stream actors, each of which man

Re: [akka-user] What is the best way to integrate kafka and akka

Nice idea with the timeout. I wrote a kafka -> rx.observable wrapper the other week too (KafkaReader.scala). I'll ponder adding your timeout trick to that interface too. Have you tried it under loaded conditions? Our ops folks have been in the habit of tuning up the kafka consumer timeout - I'm no

Re: [akka-user] DDD/Eventsourcing with Akka Persistence

Here's a pertinent reply from Patrik to me: On Mon, Mar 3, 2014 at 4:07 PM, Richard Rodseth wrote: > I haven't looked at the sources, but it seems that passivation and > clustering could be orthogonal? > yes, indeed, the high level description: - all messages are sent via the Manager actor, whi

Re: [akka-user] strange FSM (or pattern matching) behavior

Happy hAkking! :-) On Mon, Apr 14, 2014 at 10:23 PM, Scott Clasen wrote: > Oh sonofayes. Thought I had looked for that. But found it Thanks! > > > On Monday, April 14, 2014 1:17:01 PM UTC-7, √ wrote: > >> Is it the Drained object (note: not instance)? >> >> >> On Mon, Apr 14, 2014 at 10:08

Re: [akka-user] What is the best way to integrate kafka and akka

Here's the Kafka TCP protocol https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol I believe they're re-doing the high-level consumer and produce APIs as we speak. On Mon, Apr 14, 2014 at 1:14 PM, Scott Clasen wrote: > Im actually working on an actor based kafka con

Re: [akka-user] strange FSM (or pattern matching) behavior

Is it the Drained object (note: not instance)? On Mon, Apr 14, 2014 at 10:08 PM, Scott Clasen wrote: > I have an FSM that is exhibiting really strange behavior. > > I was getting warning log lines about unhanded events, so I added a > catch-all and see strangeness. > > minimally this is what it

Re: [akka-user] strange FSM (or pattern matching) behavior

Oh sonofayes. Thought I had looked for that. But found it Thanks! On Monday, April 14, 2014 1:17:01 PM UTC-7, √ wrote: > > Is it the Drained object (note: not instance)? > > > On Mon, Apr 14, 2014 at 10:08 PM, Scott Clasen > > > wrote: > >> I have an FSM that is exhibiting really strange be

Re: [akka-user] What is the best way to integrate kafka and akka

Im actually working on an actor based kafka consumer as we speak You will have to configure the consumer to not block indefinitely "consumer.timeout.ms" -> "500" then you can have a non blocking hasNext() def hasNext() = try { msgIterator.hasNext() } catch { case cte: ConsumerTi

Re: [akka-user] What is the best way to integrate kafka and akka

Sounds like an IO extension to me! On Mon, Apr 14, 2014 at 10:02 PM, Filippo De Luca wrote: > Yes polling messages and send > On Apr 14, 2014 7:47 PM, "√iktor Ҡlang" wrote: > >> Do you want to read & write etc? >> >> >> On Mon, Apr 14, 2014 at 7:59 PM, Filippo De Luca >> wrote: >> >>> I think

[akka-user] strange FSM (or pattern matching) behavior

I have an FSM that is exhibiting really strange behavior. I was getting warning log lines about unhanded events, so I added a catch-all and see strangeness. minimally this is what it looks like case object Committing case class Drained(stream:String) when(Committing) { case Event(Draine

Re: [akka-user] What is the best way to integrate kafka and akka

Yes polling messages and send On Apr 14, 2014 7:47 PM, "√iktor Ҡlang" wrote: > Do you want to read & write etc? > > > On Mon, Apr 14, 2014 at 7:59 PM, Filippo De Luca > wrote: > >> I think I will need something very similar to zeromq extension, what do >> you think? >> On Apr 14, 2014 5:54 PM,

Re: [akka-user] What is the best way to integrate kafka and akka

Do you want to read & write etc? On Mon, Apr 14, 2014 at 7:59 PM, Filippo De Luca wrote: > I think I will need something very similar to zeromq extension, what do > you think? > On Apr 14, 2014 5:54 PM, "Filippo De Luca" wrote: > >> Yes, it should. >> On Apr 14, 2014 4:28 PM, "√iktor Ҡlang" wr

Re: [akka-user] Strange timeout exception during cluster start

Interesting! Please open an Issue: https://github.com/akka/akka/issues?state=open On Mon, Apr 14, 2014 at 5:54 PM, wrote: > Hello, > > Yes. we did bind to the same port which we are using for Akka. I have > found the following offending configuration which stops from cluster > remoting to star

Re: [akka-user] DDD/Eventsourcing with Akka Persistence

Hello Kuba, Firstly, thanks for the Akka love! We <3 you too ;-) Back to your questions: Yes, the Actor would represent an Aggregate; and yes, it's a good idea to spin up Actors for specific ID's, handle the command / event in it, and emit more events signifying some business logic was performed o

Re: [akka-user] DDD/Eventsourcing with Akka Persistence

Thanks Richard, I'll definitely look into that. And it just might happen that the new activator template will come out of this :) Jakub On Monday, April 14, 2014 7:44:52 PM UTC+2, rrodseth wrote: > > Take a look at the "cluster sharding" activator template, and some of the > answers to my ques

Re: [akka-user] What is the best way to integrate kafka and akka

I think I will need something very similar to zeromq extension, what do you think? On Apr 14, 2014 5:54 PM, "Filippo De Luca" wrote: > Yes, it should. > On Apr 14, 2014 4:28 PM, "√iktor Ҡlang" wrote: > >> Should it poll if nobody is interested in reading anything? >> >> >> On Mon, Apr 14, 2014 a

Re: [akka-user] DDD/Eventsourcing with Akka Persistence

Take a look at the "cluster sharding" activator template, and some of the answers to my questions on this group. I think it would be nice to have an Activator template for DDD/Akka Persistence that didn't depend on a cluster. On Mon, Apr 14, 2014 at 9:46 AM, Jakub Czuchnowski < jakub.czuchnow...@

[akka-user] ClusterClient 'loosing' some messages sent to server!

Hi, I've been trying to test the cluster client feature on the the new akka 2.3.2 version, and i've been finding an 'abnormal' behavior partly because on inexperience and partly on the shallow scenarios available to show it practically. Here's my 2-cents scenario to simulate the issue, kindly run

[akka-user] DDD/Eventsourcing with Akka Persistence

Hi everyone, This is my first post on this group so for starters I'd like to thank the Akka team for the awesome product. Love it. I was just going through the Akka Persistence documentation and I was wondering how to achieve the event sourcing functionality as it is used in Domain Driven Desi

Re: [akka-user] What is the best way to integrate kafka and akka

Yes, it should. On Apr 14, 2014 4:28 PM, "√iktor Ҡlang" wrote: > Should it poll if nobody is interested in reading anything? > > > On Mon, Apr 14, 2014 at 5:15 PM, Filippo De Luca > wrote: > >> Hi, >> No one can help or maybe the question is too silly? >> On Apr 12, 2014 10:20 AM, "Filippo De Lu

Re: [akka-user] Strange timeout exception during cluster start

Hello, Yes. we did bind to the same port which we are using for Akka. I have found the following offending configuration which stops from cluster remoting to start. The interesting part is this causes problem only for this new cluster. Our other clusters are working fine with same code and conf

Re: [akka-user] Problems with two ActorSystems and going remote

In that case I would be very much interested in a reproducible test case, could you file a ticket on github? Thanks, Roland 14 apr 2014 kl. 17:28 skrev Curtis Stanford : > Yes, I am seeing this behaviour with 2.3.2 > > On Sunday, April 13, 2014 1:24:57 PM UTC-6, rkuhn wrote: > Hi Curtis, > >

Re: [akka-user] What is the best way to integrate kafka and akka

Should it poll if nobody is interested in reading anything? On Mon, Apr 14, 2014 at 5:15 PM, Filippo De Luca wrote: > Hi, > No one can help or maybe the question is too silly? > On Apr 12, 2014 10:20 AM, "Filippo De Luca" wrote: > >> Hi, >> I need to have actors reacting to some events arriving

Re: [akka-user] Problems with two ActorSystems and going remote

Yes, I am seeing this behaviour with 2.3.2 On Sunday, April 13, 2014 1:24:57 PM UTC-6, rkuhn wrote: > > Hi Curtis, > > which version of Akka are you using? AFAIR this was a > bug which > was fixed in the 2.1.x series: when sending to a remote Ac

Re: [akka-user] What is the best way to integrate kafka and akka

Hi, No one can help or maybe the question is too silly? On Apr 12, 2014 10:20 AM, "Filippo De Luca" wrote: > Hi, > I need to have actors reacting to some events arriving from some kafka > topics. I would like leverage on the akka supervisor mechanism to keep the > kafka consumer app and running.

[akka-user] Starting a cluster in tests--how to speed them up?

Hi- So I've got an application that lives in a small cluster. Some of our tests assert the correct behavior within a single JVM cluster we create in the test setup. While the tests are doing what we want, each test can take several minutes to run because of the cluster/singleton setup. Is there

Re: [akka-user] Re: Is there some way to save sender reference in a list when use remote akka?

Hi Liang, this is too little information for a definite answer. If you could package a small program which is able to reproduce your problem it would be great! On Fri, Apr 11, 2014 at 10:19 PM, Liang Tang wrote: > The problem is still confusing me. > > MachineB is able to periodically send mes

Re: [akka-user] Akka Persistence - Views with multiple processors

> > Entered: https://github.com/akka/akka/issues/15004 > > -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search the archives: https://groups.google.com/group/akka-user -

Re: [akka-user] Akka Actor cleans its state unexpectedly

Hi Sergey, actor probably gets restarted. You can add logging of lifecycle events with: akka { loglevel = "DEBUG" actor { debug { lifecycle = on } } } On Mon, Apr 14, 2014 at 3:25 PM, Sergey Starodubtsev wrote: > Hi Guys, > could you look at this. Maybe it is a bug or I mi

Re: [akka-user] Spring bean definition example for Routers

Hi, spring XML configuration support has been removed since Akka 2.0. You can still use Spring for DI. More information can be found by following links below: http://letitcrash.com/post/55958814293/akka-dependency-injection https://typesafe.com/activator/template/akka-java-spring On Mon, Apr 14,

Re: [akka-user] Akka Persistence - Views with multiple processors

On Mon, Apr 14, 2014 at 3:25 PM, Chanan Braunstein < chanan.braunst...@pearson.com> wrote: > Hi Patrik, > > That would be perfect for the needs I was thinking of. I hope that makes > it in to a future version. > Please create a ticket

Re: [akka-user] typesafe distributed workers example java

On Mon, Apr 14, 2014 at 2:41 PM, Karen wrote: > Hi Patrik, > > One more question, > > As discussed earlier I am successfully able to start the first node and > 2nd node, stop the first node and 2nd node takes over. So now there is 1 > node running (and it was started with port 0). How do I now

Re: [akka-user] Pattern for get or create actor?

Hi Chanan, 14 apr 2014 kl. 15:23 skrev Chanan Braunstein : > Hi Roland, > > Thanks for your answer. I haven't looked at what can be done in cluster yet > as I was trying to figure things out in one jvm first before I move to multi > jvm, but I guess I missed an important piece. I will go look

Re: [akka-user] Akka Persistence - Views with multiple processors

Hi Patrik, That would be perfect for the needs I was thinking of. I hope that makes it in to a future version. On Monday, April 14, 2014 9:22:17 AM UTC-4, Patrik Nordwall wrote: > > > > > On Mon, Apr 14, 2014 at 2:48 PM, Chanan Braunstein < > chanan.b...@pearson.com > wrote: > >> Hi Patrik, >>

[akka-user] Akka Actor cleans its state unexpectedly

Hi Guys, could you look at this. Maybe it is a bug or I missed something ? I have this actor that is involved in *parallel-word-count-calculation*. It has a state: private Map w

Re: [akka-user] Pattern for get or create actor?

Hi Roland, Thanks for your answer. I haven't looked at what can be done in cluster yet as I was trying to figure things out in one jvm first before I move to multi jvm, but I guess I missed an important piece. I will go look at now. As to the first part of you answer, I don't think I fully unde

Re: [akka-user] Akka Persistence - Views with multiple processors

On Mon, Apr 14, 2014 at 2:48 PM, Chanan Braunstein < chanan.braunst...@pearson.com> wrote: > Hi Patrik, > > Sure and if that is how akka-persistence stays, that is what we will end > up doing. But since persistence was marked as experimental, and it was > stated that it will changed based on commu

[akka-user] Change of Issue Tracker

Dear hakkers, since earlier today we have migrated our issue tracking off of Assembla and are now using GitHub Issues. We have had them enabled for quite a while in order to use labels for pull request validation, which created some confusion as to where to open tickets. Since Assembla is now r

Re: [akka-user] Akka Persistence - Views with multiple processors

Hi Patrik, Sure and if that is how akka-persistence stays, that is what we will end up doing. But since persistence was marked as experimental, and it was stated that it will changed based on community feedback, I thought I would mention this feature that seems useful and powerful to me and hop

Re: [akka-user] typesafe distributed workers example java

Hi Patrik, One more question, As discussed earlier I am successfully able to start the first node and 2nd node, stop the first node and 2nd node takes over. So now there is 1 node running (and it was started with port 0). How do I now restart the first node (that was 2552) and have it join t

Re: [akka-user] Using akka.persistence.Reset from Java

Hi Chris, that is a bug. I registered an issue here: https://github.com/akka/akka/issues/15000 On Mon, Apr 14, 2014 at 6:12 AM, Chris Toomey wrote: > I'm working on an akka app using Java, and am trying to reset a > PersistentChannel using > Reset

Re: [akka-user] Akka Persistence - Views with multiple processors

Hi Chanan, Can't you have the two views A and B forward the messages to a third aggregating actor? Regards, Patrik On Fri, Apr 11, 2014 at 12:51 PM, Chanan Braunstein < chanan.braunst...@pearson.com> wrote: > Hello, > > We are trying to evaluate using Akka persistence to use going forward in >

Re: [akka-user] Wireshark tells me, that the data arrived 17 seconds before akka raises a Received event, why?

I do not think that this is a time issue. Reason is: When the client closes the connection within this 16/17 seconds, then the server never gets to register for the connection. I receive a message was delivered to dead-letters message, for the Register message. I am currently investigating to r