Re: 如何按比例丢弃kafka中消费的数据

自定义 kafkasource 的 DeserializationSchema
丢弃的返回 null， source 的下一个filter 算子进行过滤即可


> 2022年2月26日 上午9:01，jack zhang <freerain...@outlook.com> 写道：
> 
> 1、flink程序资源有限，kafka中数据比较多，想要按一定比例丢弃数据(或者其它策略)，减轻flink 程序压力，有什么方法吗？

回复