You can add a back pressured enabled component in front that feeds data into Spark. This component can control in input rate to spark.
> On Jun 18, 2014, at 6:13 PM, Flavio Pompermaier <pomperma...@okkam.it> wrote: > > Hi to all, > in my use case I'd like to receive events and call an external service as > they pass through. Is it possible to limit the number of contemporaneous call > to that service (to avoid DoS) using Spark streaming? if so, limiting the > rate implies a possible buffer growth...how can I control the buffer of > incoming events waiting to be processed? > > Best, > Flavio
