[akka-user] Re: Node quarantined

Yeah sorry I thought it was related with rolling restart. As for Netty, I'm using a *non-published yet* Netty with the following fixes: https://github.com/netty/netty/issues?q=milestone%3A3.10.6.Final+is%3Aclosed You can just get it from Git and: $ git checkout 3.10 $ mvn versions:set

[akka-user] Re: Node quarantined

Hi Guido, yes I'm aware of the leaving cluster conversation as I started it :-) This is separate issue. I am observing this behavior whilst the cluster seems stable with no nodes being added/removed. I suspect that this issue was first observed when I upgraded a different library that brought

[akka-user] Re: Node quarantined

Hi Benjamin, You have nodes with predefined ports, one thing I have which eliminates that problem for these nodes is that only my seed node(s) have the port set, the rest will just get a dynamic and available port, making it get a different port when you do a rolling restart. I suspect you are

[akka-user] Re: Node quarantined

Hi Benjamin, You have nodes with predefined ports and addresses, one thing I have which eliminates that problem for these nodes is that only my seed node(s) have the port set, the rest will just get a dynamic and available port, making it get a different port when you do a rolling restart. I

[akka-user] Re: Node quarantined

I see the same issue with 2.3.14. On Tuesday, March 22, 2016 at 2:00:15 PM UTC-4, Guido Medina wrote: > > To eliminate noise please update to 2.3.14 which from 2.3.11 has some > cluster fixes, there are also several fixes on Scala 2.11.8 (not related) > > I don't know, I just have the custom of

Re: [akka-user] Re: Can this be done with the build in stages?

I like the throttle version more ;) On Sun, Mar 20, 2016 at 4:24 PM, Roland Kuhn wrote: > Yes, and for the immediate case you can use Future.successful. > > Regards, Roland > > Sent from my iPhone > > On 20 Mar 2016, at 15:41, john.vie...@gmail.com wrote: > > Something very

Re: [akka-user] Re: Can't get akka clustering to work in docker

Hi Endre, I have read that part of the documentation, and after switching to a new cassandra journal keyspace, everything is working as it should be. I've confirmed that if I bump the "ECS Service" count to 2 (or greater), the ECS Task (describing an akka-cluster-sharding application) gets

Re: [akka-user] Re: Can this be done with the build in stages?

Yes, and for the immediate case you can use Future.successful. Regards, Roland Sent from my iPhone > On 20 Mar 2016, at 15:41, john.vie...@gmail.com wrote: > > Something very simple which come to my mind is to mapAsync to the ask > pattern and then do a "schedule of 10 secs" if the element

Re: [akka-user] What is the impact of Kafka Streams on reactive-kafka?

It looks like Kafka Streams is more of a distributed framework, does balancing, the app can be moved, etc. RS based streams on the other hand are more lightweight and local. I.e. after reading this article this looks like an apples vs. oranges comparison for now. -Endre On Tue, Mar 22, 2016 at

Re: [akka-user] What is the impact of Kafka Streams on reactive-kafka?

> For reference, Kafka Streams is this thing: > http://www.confluent.io/blog/introducing-kafka-streams-stream-processing-made-simple > > > > Reactive Kafka is (or will be) a Kafka connector to/from Akka

Re: [akka-user] Rejections in Akka HTTP Java API

There's a completely new javadsl coming in the next weeks, it will have rejections (and docs for them) :) Thanks for your patience! On Mar 22, 2016 15:37, "Adam" wrote: > Hi, > > I see Rejections are only described in the Scala version of the docs. > Is that on purpose? >

Re: [akka-user] Rejections in Akka HTTP Java API

Cool. Thanks for quick response! On Tue, Mar 22, 2016 at 4:41 PM, Konrad Malawski < konrad.malaw...@lightbend.com> wrote: > There's a completely new javadsl coming in the next weeks, it will have > rejections (and docs for them) :) > > Thanks for your patience! > On Mar 22, 2016 15:37, "Adam"

[akka-user] Rejections in Akka HTTP Java API

Hi, I see Rejections are only described in the Scala version of the docs. Is that on purpose? What are my options using the Java API in order to customize rejections? -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

[akka-user] stash with big queues

I've got an FSM with Stash, something like this when (Idle) case Event(cmd: ...) process() // asynchronous activity goto Processing when(Processing) case Event(updated:...) // do something with result unstashAll() goto (Idle) case Event(cmd: ..) stash() stay

Re: [akka-user] Re: Can this be done with the build in stages?

Hi John, I think it is easier to use the built-in throttle: - set the capacity to zero - set the token rate to 1/second - use an explicit cost function, setting the cost of non-empty sequences to zero, and the cost of empty-ones to ten. -Endre On Sun, Mar 20, 2016 at 6:06 PM,

Re: [akka-user] Re: Can't get akka clustering to work in docker

Hi Eric, I have no experience with Docker at all, but it does feel wrong (unless very specific use-cases) to have separate journals and snapshot stores *per-node*. I think you might have an issue with Docker NAT. Have you read this part of the documentation:

Re: [akka-user] What is the impact of Kafka Streams on reactive-kafka?

For reference, Kafka Streams is this thing: http://www.confluent.io/blog/introducing-kafka-streams-stream-processing-made-simple Reactive Kafka is (or will be) a Kafka connector to/from Akka Streams (and thereby also Reactive Streams). It looks like Kafka Streams provides another streaming DSL,

Re: [akka-user] Detecting empty source

…and, an empty source is one which signals onComplete before any data has passed through. :) On Tue, Mar 22, 2016 at 10:58 AM, Akka Team wrote: > Hi Richard, > > There is no other way to detect whether a Source is empty than to run it. > For example if a Source wraps a

Re: [akka-user] What is the impact of Kafka Streams on reactive-kafka?

Hi Axel, I am not sure what the question is about here. Anyway, reactive-kafka is not just about reading from Kafka, it also provides a Reactive Streams based interface that allows interoperability with anything that implements RS. -Endre On Sat, Mar 19, 2016 at 1:17 PM, 'Axel Poigné' via Akka

Re: [akka-user] Detecting empty source

Hi Richard, There is no other way to detect whether a Source is empty than to run it. For example if a Source wraps a DB query then of course it is impossible to see if the query will be empty or not without actually materializing and hence running the query. -Endre On Mon, Mar 21, 2016 at 4:59

[akka-user] Usage of EventFilters in akka.testkit

Dear reader, I've seen in the documentation that it is possible to do assertions on Akka log messages. http://doc.akka.io/docs/akka/current/scala/testing.html#Expecting_Log_Messages But the documentation is here a bit sparsely and doesn't explain how to do "non-exception" assertions. You can

Re: [akka-user] How-to restart a RunnableGraph on failure?

On Mon, Mar 21, 2016 at 7:27 PM, Viktor Klang wrote: > "The only thing worse than not saying anything, is telling a lie." > This does not apply here. The termination Future would correctly signal that all stages that has been materialized by that materializer has been

[akka-user] How implement recursion in futures correctly? (Java)

I am having a hard time understanding how to use futures specifically when it comes to implementing functions within those futures. So for example, if I wanted to implement factorial in a future using this algorithm: int factorial(int n) { if (n == 0) return 1; else