[
https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16442918#comment-16442918
]
buptljy commented on FLINK-9178:
--------------------------------
[~till.rohrmann] Do you have ideas about this issue ? Maybe it can be a new
feature for the source ?
> 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 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)
