Re: [akka-user] Slow reactive-kafka consumer when running multiple streams

Hi, We have several streams in the same runtime and it works fine. We did, however, have problems when trying _a lot_ of consumers (~100, iirc), and ended up sharing. Tal On Tuesday, February 13, 2018 at 1:37:24 AM UTC+2, rrodseth wrote: > > Anyone else running more than one stream in a

Re: [akka-user] Slow reactive-kafka consumer when running multiple streams

Anyone else running more than one stream in a deployable? Surely the answer must be yes. Would love to know what the problem might be. On Wed, Dec 27, 2017 at 10:02 AM, Harshit Patel wrote: > We have an application that uses reactive-kafka to consume messages from a >

Re: [akka-user] Message processed by Actors

On Mon, Feb 12, 2018 at 11:26 AM, Kilic Ali-Firat wrote: > Hi Akka team, > I'm not the Akka team, but... > case class Worker() extends Actor { > > > trait Message > case class M1(x : Int) extends Message > case class M2(x : Int) extends Message > > > trait

[akka-user] Akka HTTP 10.1.0-R2 Released

Dear hakkers, we are happy to announce Akka Http 10.1.0-RC2, the second release candidate for the upcoming Akka HTTP 10.1.0 release. We focused on stabilizing the new client connection pool. Over the last month our test suite caught lots of edge cases that were fixed for this release. Also,

[akka-user] Message processed by Actors

Hi Akka team, I have a question about messages processing by an Actor. In the context of my Akka application, I defined an Actor with a similar behavior : case class Worker() extends Actor { trait Message case class M1(x : Int) extends Message case class M2(x : Int) extends Message

[akka-user] Re: Cannot configure the Akka Http server when using the akka-http-spring-boot library

No, sorry. On Thursday, February 8, 2018 at 4:22:25 AM UTC-5, Som Shankar Bhattacharyya wrote: > > I am trying to setup a project that runs REST services on top of a AKK > HTTP server yet managed by Spring boot. > Now i found this project on gihub as a reference and am using that as >

[akka-user] Re: Accessing SourceQueue or ActorRef inside Graph for publishing elements

use zip method On Sunday, 22 November 2015 23:49:14 UTC+8, Muki wrote: > > Hi, > > I have a stream pipeline like this: > > progress queue+-> mapping +-+ > | >^^^ | >|||

Re: [akka-user] Akka Cluster Http Management Setup

Hi Konrad, It was the first time that I was using akka management, reading the documentation I was missing a start() and a stop() in my code :) Thank you ! Le lundi 12 février 2018 10:49:58 UTC+1, Konrad Malawski a écrit : > > You did not say which versions of libs you’re on, please say that

Re: [akka-user] Akka Cluster Http Management Setup

Happy hakking~! -- Cheers, Konrad 'ktoso ' Malawski Akka @ Lightbend On February 12, 2018 at 11:04:28, Kilic Ali-Firat (kilic.alifi...@gmail.com) wrote: Hi Konrad, It was the first time that I was using akka management, reading the

Re: [akka-user] Akka Cluster Http Management Setup

You did not say which versions of libs you’re on, please say that always in such threads :) Assuming latest versions. The 2551 port is NOT the port that any HTTP is on; it’s where Akka remoting is bound to, HTTPing onto that one is not right :) How did you start the management endpoint? You’d

[akka-user] Akka Cluster Http Management Setup

Hi guys, I'm started to play with Akka Cluster HTTP management. I have a project of an Akka Cluster in which I added dependencies (latest) to have informations about my cluster members. I have two seed nodes : one starting on port 2551 and other one 2552. The seed nodes are joining the