buptljy created FLINK-9178: ------------------------------ Summary: 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
When I want to run the flink program from the earliest offset in Kafka, it'll be very easy to cause OOM because of too many HeapMemorySegment in NetworkBufferPool. I think we should support this "rerun" situation, which is very common for most businesses. -- This message was sent by Atlassian JIRA (v7.6.3#76005)