Re: [akka-user] Re: Issue in Sending messages through akka cluster.

Work pulling (see my previous link) might be a good choice. Note that it's not only about that the end consumers might not consume fast enough, it's also anything on the way there, such as serialization and deserialization (which I think is your bottleneck). On Thu, May 25, 2017 at 1:16 PM, chait

Re: [akka-user] Re: Issue in Sending messages through akka cluster.

We used Single Producer and Multiple Consumer pattern On Thursday, 25 May 2017 15:56:15 UTC+5:30, chaitanya wrote: > > " The buffers in Artery are bounded and will start dropping messages if > overwhelmed " - > > which pattern would be best to resolve this issue and faster? > > > On Wednesday, 24

Re: [akka-user] Re: Issue in Sending messages through akka cluster.

" The buffers in Artery are bounded and will start dropping messages if overwhelmed " - which pattern would be best to resolve this issue and faster? On Wednesday, 24 May 2017 17:54:11 UTC+5:30, Patrik Nordwall wrote: > > You have to implement some flow control, such as as using the "Work > Pu

Re: [akka-user] Re: Issue in Sending messages through akka cluster.

You have to implement some flow control, such as as using the "Work Pulling" pattern , throttling, or send acknowledgment messages back from the consumer. If producer is sending messages at a higher rate tha

[akka-user] Re: Issue in Sending messages through akka cluster.

Following is the console output of my program it says Dropping messages due to overflow of send queue. How to solve this? GET Messages >>> Content GET Messages >>> Content 12:49:35.091 [ClusterSystem-akka.actor.default-dispatcher-3] DEBUG a.r.a.Association(akka://Clust