Hi Suraj Puvvada Yes, Flink back pressure depend on the Flink task buffer。process task will sends buffer remaining size to source, source will slow down.
https://www.ververica.com/blog/how-flink-handles-backpressure <https://www.ververica.com/blog/how-flink-handles-backpressure> Jake > On Jul 31, 2020, at 2:48 AM, Suraj Puvvada <su...@traceable.ai> wrote: > > Hello > > I am trying to understand if Flink has a mechanism to automatically apply any > backpressure by throttling any operators ? For example if I have a Process > function that reads from a Kafkaa source and writes to a Kafka sink. If the > process function is slow will the kafka source be automatically throttled ? > > Thanks > Suraj
