[
https://issues.apache.org/jira/browse/FLINK-5445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin closed FLINK-5445.
-------------------------------
Resolution: Duplicate
Fix Version/s: 1.8.0
> flink kafka consumer should support rate control
> ------------------------------------------------
>
> Key: FLINK-5445
> URL: https://issues.apache.org/jira/browse/FLINK-5445
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
> Affects Versions: 1.1.3
> Reporter: Renjie Liu
> Priority: Critical
> Fix For: 1.8.0
>
>
> Now kafka connector does not support rate control at all, this may lead
> checkpoints to fail and expire if downstream processor is slow. Though this
> will not compromise the guarantee of flink's checkpoint, this will stop kafka
> consumer from comitting offsets since kafka consumer commits offsets in the
> callback of checkpoint complete. The committed offsets is important for
> monitoring purpose. So I think we need to support rate limit control in kafka
> consumer.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
