You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Zain Haider Nemati <za...@retailo.co> on 2022/05/17 20:50:13 UTC

Memory configuration for Queue

Hi,
I am using a kafka source with a kinesis sink and the speed of data coming
in is not the same as data flowing out hence the need to configure a
relatively larger queue to hold the data before backpressuring. Which
memory configuration corresponds to this that I'll need to configure?