Recommend token bukets! Here is a solid implementation:
https://github.com/bbeck/token-bucket
On Fri, 5 Feb 2016 at 03:33 Jagadish Venkatraman
wrote:
> Hi Ramesh,
>
> I understand that you want to limit the calls to the destination service.
> Currently, there's no framework level support for thr
Hi Ramesh,
I understand that you want to limit the calls to the destination service.
Currently, there's no framework level support for throttling in Samza
(yet). But, since Samza is single threaded, you can trivially implement
some form of throttling by calling Thread.sleep() in the StreamTask.pro
Can I ask why you’re using samza and kafka for this?
> On Feb 4, 2016, at 7:41 PM, ramesh shanmugam
> wrote:
>
> Hi Team,
>
> We have use case that destination system accept only 160 messages per
> minute.
>
> Planning to use Samza with Kafka. Looking for out of box throttling feature
> but
Hi Team,
We have use case that destination system accept only 160 messages per
minute.
Planning to use Samza with Kafka. Looking for out of box throttling feature
but not able locate in documenttion.
Can you please suggest how throttling can be achieved in Samza?.
--
Thanks
Ramesh
