回复:当kafka有大量数据积压并且flink冷启动,flink端读取kafka有没有限流的参数?

classic Classic list List threaded Threaded
1 message Options
me
Reply | Threaded
Open this post in threaded view
|

回复:当kafka有大量数据积压并且flink冷启动,flink端读取kafka有没有限流的参数?

me
flink版本1.11
flink连接kafka使用的是 flink  addSource特性


 原始邮件
发件人: me<[hidden email]>
收件人: user-zh<[hidden email]>
发送时间: 2020年9月27日(周日) 17:22
主题: 当kafka有大量数据积压并且flink冷启动,flink端读取kafka有没有限流的参数?


当kafka有大量数据积压并且flink冷启动,flink端读取kafka有没有限流的参数? kafka积压了2亿数据,flink启动后接着之前的状态读取,怎么控制flink的限流?