Re: [akka-user] Akka Stream stalling with JsonFraming

I figured it out. Submitting a pull request! On Tuesday, December 6, 2016 at 12:29:28 PM UTC-7, Konrad Malawski wrote: > > Is the JSON well formed and "normal" or something weird or maybe huge > objects or something in there etc? > Try to debug at which point it gets stuck. > > A minimized

[akka-user] Persistence with Avro

Anyone else using Avro and avro4s to serialize persistence events? I was able to get the SerializerWithStringManifest below working (with generic serialize and deserialize methods). Should I be extending something other than SerializerWithStringManifest, given that Avro on its own helps with

Re: [akka-user] Akka Stream stalling with JsonFraming

Is the JSON well formed and "normal" or something weird or maybe huge objects or something in there etc? Try to debug at which point it gets stuck. A minimized reproducer would help. -- Konrad `ktoso` Malawski Akka @ Lightbend On 6 December 2016 at

[akka-user] Akka Stream stalling with JsonFraming

I working on a Akka Streams project that reads gzipped files from S3 and parses json. The issue I'm running into the stream stalls at about 24523530 bytes and then times-out after a 1 minute (java.util.concurrent.TimeoutException: No elements passed in the last 1 minute), but there is no error

[akka-user] Cluster Sharding custom routing

Hello! >From what I understand, the cluster sharder GracefulShutdown implementation, removes the node from the cluster. It also signals all the remaining nodes to buffer any messages that target shards already allocated on the given node. I believe this is because the use case assumes

[akka-user] Java TestProbe with ReceiveWhile

In the Akka Scala API you can call receiveWhile to receive messages sent to a TestProbe: val msgs = testProbe.receiveWhile(5.seconds) { case x *=> ...* } In the Java API you can do something similar, but I could not find a way to use ReceiveWhile with a TestProbe: final CurrentState[]

Re: [akka-user] (akka-http) server.max-connections vs max socket opening/s

Before using ab I was stressing the app with Gatling which does not reuse connections between users. In order to simplify my demonstration I switched to ab without keepalive to keep the same scenario. I will have a look to wrk. Please do remember to benchmark not the same box on which you're

Re: [akka-user] (akka-http) server.max-connections vs max socket opening/s

Thanks for answering so quickly. Indeed the performance is much better if I reuse tcp connections. Before using ab I was stressing the app with Gatling which does not reuse connections between users. In order to simplify my demonstration I switched to ab without keepalive to keep the same

Re: [akka-user] invalid materialized value

Yes, this is a bug. I filed a ticket: https://github.com/akka/akka/issues/21955 On Tue, Dec 6, 2016 at 10:39 AM, Endre Varga wrote: > Hi Stefan, > > What version are you using? This might be a bug. > > -Endre > > On Tue, Dec 6, 2016 at 10:13 AM, EXTERNAL Wachter

Re: [akka-user] (akka-http) server.max-connections vs max socket opening/s

Your benchmark is likely unrealistic - it should use consistent connections to give any kind of realistic numbers (clients always keep connections). ab is also not the best tool around (hasn't been since a long time), please try `wrk`. Your benchmark is effectively benchmarking materialization

[akka-user] (akka-http) server.max-connections vs max socket opening/s

Hi I'm testing akka-http and I try to measure how many concurrent connections it can handle on my company's Linux VM (x86_64, 4 CPU). I use the simple http server implementation provided in the akka-http documentation which you can find in the following github project created for illustrating

Re: [akka-user] invalid materialized value

Hi Stefan, What version are you using? This might be a bug. -Endre On Tue, Dec 6, 2016 at 10:13 AM, EXTERNAL Wachter Stefan (Keybird IT Consulting und Vetriebs GmbH, INST-ICM/BSV-BS) < external.stefan.wach...@bosch-si.com> wrote: > Hi all, > > > > the following line of code > > > > > > *val

[akka-user] invalid materialized value

Hi all, the following line of code val ((pub, mat), sub) = TestSource.probe[Int].viaMat(Flow[Int])(Keep.both).toMat(TestSink.probe)(Keep.both).run() throws a ClassCastException: java.lang.ClassCastException: akka.stream.testkit.TestPublisher$Probe cannot be cast to scala.Tuple2 it seems