[ https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16455677#comment-16455677 ]
buptljy commented on FLINK-9178: -------------------------------- [~app-tarush] I think so, and there is another option is using the limitation of bytes for every second, but I think the strategy fo using the amount of events is better. > Add rate control for kafka source > --------------------------------- > > Key: FLINK-9178 > URL: https://issues.apache.org/jira/browse/FLINK-9178 > Project: Flink > Issue Type: Improvement > Components: Kafka Connector > Reporter: buptljy > Priority: Major > > When I want to run the flink program from the earliest offset in Kafka, it'll > be very easy to cause OOM if there are too much data, because of too many > HeapMemorySegment in NetworkBufferPool. > Maybe we should have some settings to control the rate of the receiving data? -- This message was sent by Atlassian JIRA (v7.6.3#76005)