应该是没有的,可以自己改造下kafka source来实现。
话说flink自动反压流控不能满足场景需要吗

me <m...@lishiyu.cn> 于2020年9月27日周日 下午5:45写道:

> flink版本1.11
> flink连接kafka使用的是 flink  addSource特性
>
>
>  原始邮件
> 发件人: me<m...@lishiyu.cn>
> 收件人: user-zh<user-zh@flink.apache.org>
> 发送时间: 2020年9月27日(周日) 17:22
> 主题: 当kafka有大量数据积压并且flink冷启动,flink端读取kafka有没有限流的参数?
>
>
> 当kafka有大量数据积压并且flink冷启动,flink端读取kafka有没有限流的参数?
> kafka积压了2亿数据,flink启动后接着之前的状态读取,怎么控制flink的限流?

回复