你好，使用 DataStream API 的话你可以在读入数据后紧接着用 filter 方法根据一定策略过滤掉一部分数据再进行业务处理即可。
Best, Zhanghao Chen ________________________________ From: jack zhang <freerain...@outlook.com> Sent: Saturday, February 26, 2022 9:01 To: user-zh@flink.apache.org <user-zh@flink.apache.org> Subject: 如何按比例丢弃kafka中消费的数据 1、flink程序资源有限，kafka中数据比较多，想要按一定比例丢弃数据(或者其它策略)，减轻flink 程序压力，有什么方法吗？
