Simple idea: create a map function that only does "sleep 1/5 second" and put that in your pipeline somewhere.
Niels On 16 Apr 2016 22:38, "Chen Bekor" <chen.be...@gmail.com> wrote: > is there a way to consume a kafka stream using flink with a predefined > rate limit (eg 5 events per second) > > we need this because we need to control some 3rd party api rate > limitations so, even if we have a much larger throughput potential, we > must control the consumption rate in order not to overflow the API channel. >
