请问下, 有没有什么方法能够 限制 flink 消费 kafka 的速度?

1. flink不是自带限流 FlinkConnectorRateLimitter
2. 自己用guava 实现限流
3. 配置kafka的消费参数 让他每次获取的少一些，获取时间长一些
4. 随便在kafka后面加个算子 sleep 1毫秒 用被压 来限制 此回答整理自钉群“【③群】Apache Flink China社区”

您好，可以参考这篇文章限制速度：https://blog.csdn.net/m0_57320261/article/details/127277118。

可以调整 fetch.max.bytes 参数来控制单次获取数据的最大消息数。还可以调整 max.poll.records 参数来控制单次 poll 调用返回的最大消息数。如果处理逻辑很轻量，可以适当提高该值。