Hi Patrick,
I have the same question, sorry - I did not get the solution from your
reply. If in-flight messages are not stored anywhere, how do I deal with a
node crash?
If I use channels, how does it help solve the problem? Even if the channel
persists messages, once it is pulled out from the queue, it is gone - right?
Thanks
-gc
On Friday, April 25, 2014 8:47:30 PM UTC+5:30, Patrik Nordwall wrote:
>
> Hi,
>
>
> On Fri, Apr 25, 2014 at 4:01 PM, Patrik Nordwall
> <[email protected]<javascript:>
> > wrote:
>
>> First of all, use latest stable release: 2.3.2
>> /Patrik
>>
>>
>> On Fri, Apr 25, 2014 at 2:45 PM, George Wilk
>> <[email protected]<javascript:>
>> > wrote:
>>
>>> Dependencies:
>>> - akka-persistence-experimental 2.3.0
>>> - akka-actor 2.3.0
>>> - akka-contrib 2.3.0
>>>
>>> We are building large CQRS system utilizing Akka-persistence with
>>> cluster sharding in akka-contrib,
>>> deploying multiple EventsourcedProcessors distributed on several cluster
>>> nodes.
>>>
>>> As part of application resilience testing we are running the following
>>> test scenario:
>>>
>>> - 2 akka nodes (node_1 and node_2) in 2 individual VMs deployed on 2
>>> separate servers
>>> - bring the cluster up and let it acquiesce: first node_1 then node_2
>>> - start generating event messages
>>> - while under load, shut down one of the VMs - node_2 (non-seed node)
>>> - observe cluster state: several in-process event messages being
>>> processed by the processor
>>> on shut down VM are incomplete/unprocessed. This is expected as result
>>> of VM crash.
>>> - unprocessed events are not replayed while node_2 is down.
>>> - restart node_2. Expected to see unprocessed events to be replayed,
>>> but it does not happen.
>>> - restart cluster in the same order as in original setup: first node_1,
>>> then node_2
>>> - observe cluster state: unprocessed messages have been replayed
>>>
>>> Questions:
>>> 1) should we expect that once node failure (processor failure) is
>>> detected by akka cluster
>>> the unprocessed events will be replayed while the failed node (node_2)
>>> is still down?
>>>
>>
> Messages in flight have not been stored and will not be replayed anywhere.
> How do you send the messages? Do you use channels?
>
>
>> 2) if answer to 1) is NO, should we expect that unprocessed events will
>>> be replayed once
>>> failed node (node_2) comes back online?
>>> 3) is there a difference in cluster behavior when the failed node is a
>>> seed node vs. non-seed
>>> node?
>>>
>>
> No, seed nodes are only initial contact points for new nodes joining the
> cluster. Apart from that they are exactly the same as all other nodes.
>
> Regards,
> Patrik
>
>
>>
>>> Thanks in advance!
>>> ~g
>>>
>>> --
>>> >>>>>>>>>> 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
>>> ---
>>> You received this message because you are subscribed to the Google
>>> Groups "Akka User List" group.
>>> To unsubscribe from this group and stop receiving emails from it, send
>>> an email to [email protected] <javascript:>.
>>> To post to this group, send email to [email protected]<javascript:>
>>> .
>>> Visit this group at http://groups.google.com/group/akka-user.
>>> For more options, visit https://groups.google.com/d/optout.
>>>
>>
>>
>>
>> --
>>
>> Patrik Nordwall
>> Typesafe <http://typesafe.com/> - Reactive apps on the JVM
>> Twitter: @patriknw
>> JOIN US. REGISTER TODAY! <http://www.scaladays.org/>
>> Scala <http://www.scaladays.org/>
>> Days <http://www.scaladays.org/>
>> June 16th-18th, <http://www.scaladays.org/>
>> Berlin <http://www.scaladays.org/>
>>
>>
>
>
> --
>
> Patrik Nordwall
> Typesafe <http://typesafe.com/> - Reactive apps on the JVM
> Twitter: @patriknw
> JOIN US. REGISTER TODAY! <http://www.scaladays.org/>
> Scala <http://www.scaladays.org/>
> Days <http://www.scaladays.org/>
> June 16th-18th, <http://www.scaladays.org/>
> Berlin <http://www.scaladays.org/>
>
>
--
>>>>>>>>>> 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
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
