业务表存量数据很大,如果不加限流直接使用flink cdc读取snapshot阶段数据的话会造成业务库压力,触发数据库告警,影响在线业务。
请问Flink CDC中如何在Snapshot阶段读取数据时进行限流?


我看到社区之前有人提议过,但issue一直是open状态
https://issues.apache.org/jira/browse/FLINK-18740


另外,我在flink最新master分支源码中有找到 
GuavaFlinkConnectorRateLimiter,但没有找到调用它的例子,请问如何在flink作业中使用限流呢?

回复